Unlock a world of possibilities! Login now and discover the exclusive benefits awaiting you.
I have a data integration job that used apache camel to produce rabbitmq messages to a queue. I want the job to publish over a ssl encrypted channel. In the apache camel documentation I see the trustManager and sslProtocol properties. How do I configure the sendBodyAndHeaders method to publish on ssl? I do not see this in any of the documentation either in Talend or Apache for integration jobs.
the tJavaFlex code working non-secure (no ssl):
Start code:
// start part of your Java code
org.apache.camel.ProducerTemplate localmdsProducer = (org.apache.camel.ProducerTemplate) globalMap.get("camelProducer");
String srabbitURI2S=context.rabbitmqBaseUri+"/"+context.rabbitmqExchange+"?routingKey="+context.mdsroutingKey+"&declare="+context.rabbitmqDeclare+"&durable="+context.rabbitmqDurable+"&exchangeType="+context.rabbitmqExchangeType+"&autoDelete="+context.rabbitmqAutoDelete+"&username="+context.rabbitmqusername+"&password="+context.rabbitmqpassword;
java.util.Map<String, Object> headers = new java.util.HashMap<String, Object>();
headers.put("rabbitmq.ROUTING_KEY", context.mdsroutingKey);
Main code:
localmdsProducer.sendBodyAndHeaders(srabbitURI2, row7.output,headers);
Thanks!