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

Announcements
Join us in Toronto Sept 9th 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.