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