package com.megatim.fdxconsultation.service.impl.camel.routes.out;

import com.megatim.fdxcommons.model.jms.messages.ApiTokenMessage;
import com.megatim.fdxcommons.tools.CommonAppContext;
import com.megatim.fdxconsultation.service.resolvers.JacksonMapperFormat;
import com.megatim.fdxconsultation.tools.context.AppCommonContext;
import org.apache.camel.builder.RouteBuilder;

/**
 *
 * @author Gabuntu
 */
public class DirectToTokenGenerationKafkaRoute extends RouteBuilder {

    @Override
    public void configure() throws Exception {

        from("direct:" + AppCommonContext.TOKEN_GENERATION_DIRECT)
                .process(ex -> {
                    System.out.println("in DirectToTokenGenerationQueueRoute codeParticipant = " + ((ApiTokenMessage) ex.getIn().getBody()).getCodeParticipant());
                    System.out.println("token = " + ((ApiTokenMessage) ex.getIn().getBody()).getToken());
                })
                .marshal(JacksonMapperFormat.jacksonDataFormat(ApiTokenMessage.class))
                .to("rabbitmq:"
                        + CommonAppContext.TOKEN_GENERATION_EXCHANGE
                        + "?queue=" + CommonAppContext.TOKEN_GENERATION_QUEUE
                        + "&routingKey=" + CommonAppContext.TOKEN_GENERATION_ROUTING_KEY
                        + "&autoDelete=false");
    }

}