Do not input private or sensitive data. View Qlik Privacy & Cookie Policy.
Skip to main content

Announcements
Join us in Bucharest on Sept 18th for Qlik's AI Reality Tour! Register Now
cancel
Showing results for 
Search instead for 
Did you mean: 
Anonymous
Not applicable

Producing camel rabbitmq message over ssl

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!

Labels (2)
1 Reply
Anonymous
Not applicable
Author

As far as I know, the rabbit-mq is not compatible with the current Camel release. I suggest you use the Apache MQ.