package com.megatim.apifdxweb.service.impl.camel.consumers; import com.megatim.apifdxweb.core.ifaces.administration.UserManager; import com.megatim.apifdxweb.core.ifaces.referentiel.ParticipantManager; import com.megatim.fdxcommons.model.jms.messages.ApiTokenMessage; import com.megatim.fdxcommons.model.referentiel.Participant; import javax.inject.Inject; import org.apache.camel.Handler; /** * * @author ASUS */ public class ApiTokenMessageConsumer { @Inject private UserManager userManager; @Inject private ParticipantManager participantManager; @Handler public void saveTokenAuthentification(ApiTokenMessage apiTokenMessage) throws Exception { Participant participant = participantManager.getById(apiTokenMessage.getCodeParticipant()); if (participant != null) { switch (apiTokenMessage.getApiTokenMessageType()) { case ADD: userManager.addUser(participant, apiTokenMessage.getToken()); break; case UPDATE: userManager.updateUser(participant, apiTokenMessage.getToken()); break; case LOCKED: userManager.lockUser(participant); break; case UNLOCKED: userManager.unLockUser(participant); break; } } } }