package com.megatim.fdxconsultation.service.impl.camel.consumer;

import com.fdx.messaging.common.ConnexionStatutMessages;
import com.megatim.fdxconsultation.service.impl.sockets.helpers.ConnexionStatutSessionHandler;
import javax.inject.Inject;
import org.apache.camel.Handler;

/**
 *
 * @author lenovo
 */
public class ConnexionStatutConsumer {

    @Inject
    private ConnexionStatutSessionHandler connexionStatutSessionHandler;

    @Handler
    public void process(ConnexionStatutMessages connexionStatutMessages) throws Exception {
        connexionStatutMessages.getConnexionStatuts().forEach(c -> System.out.println(c.getAgentCode() + " " + c.isConnected()));
        connexionStatutSessionHandler.publishMessage(connexionStatutMessages.getConnexionStatuts());
    }

}