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;
|
}
|
}
|
|
}
|
}
|