package com.megatim.apifdxweb.service.impl.camel.consumers;
|
|
import com.megatim.apifdxweb.core.ifaces.log.UserActionLogManager;
|
import com.megatim.fdxcommons.model.log.UserActionLog;
|
import javax.inject.Inject;
|
import org.apache.camel.Handler;
|
import org.apache.camel.ProducerTemplate;
|
import org.apache.camel.cdi.CdiCamelContext;
|
|
/**
|
*
|
* @author ASUS
|
*/
|
public class UserActionLogConsumer {
|
|
@Inject
|
private UserActionLogManager logManager;
|
|
@Inject
|
private CdiCamelContext camelContext;
|
|
@Handler
|
public void process(UserActionLog log) throws Exception {
|
|
UserActionLog refreshEntity = logManager.save(log);
|
ProducerTemplate producerTemplate = camelContext.createProducerTemplate();
|
|
producerTemplate.sendBody("direct:" + com.megatim.fdxcommons.tools.context.AppContext.USER_ACTION_TO_FDX_CONS_DIRECT, refreshEntity);
|
}
|
}
|
