/* * Click nbfs://nbhost/SystemFileSystem/Templates/Licenses/license-default.txt to change this license * Click nbfs://nbhost/SystemFileSystem/Templates/Classes/Class.java to edit this template */ package com.megatim.fdxconsultation.service.impl.camel.routes.out; import com.megatim.fdxcommons.model.dtos.remoteproduction.RemoteConfigurationDto; import com.megatim.fdxcommons.tools.context.AppContext; import com.megatim.fdxconsultation.service.resolvers.JacksonMapperFormat; import com.megatim.fdxconsultation.tools.context.AppCommonContext; import org.apache.camel.builder.RouteBuilder; /** * * @author ASUS */ public class RemoteConfigurationRoute extends RouteBuilder { @Override public void configure() throws Exception { onException(Exception.class) .handled(false) .log("Exception occured: ${exception.message}") .logStackTrace(true) .end(); from("direct:" + AppCommonContext.REMOTE_CONGIGURATION_DIRECT) .marshal(JacksonMapperFormat.jacksonDataFormat(RemoteConfigurationDto.class)) .to("rabbitmq:" + AppContext.REMOTE_CONFIGURATION_EXCHANGE + "?queue=" + AppContext.REMOTE_CONFIGURATION_QUEUE + "&routingKey=" + AppContext.REMOTE_CONFIGURATION_ROUTING_KEY + "&autoDelete=false" + "&durable=true"); } }