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

Announcements
Qlik Connect 2026 Agenda Now Available: Explore Sessions
cancel
Showing results for 
Search instead for 
Did you mean: 
ORo1
Contributor
Contributor

cMessagingEndpoint and RabbitMQ (ESB Mediation)

Dear all,
I'd like to read messages from RabbitMQ. For that I've done the following:

I created a new route
I added a cMessagingEndpoint on the "job" with "rabbitmq" in Advanced Settings and the following URI: "rabbitmq://127.0.0.1:5672/myExchangeName?queue=myQueue"
with the assumption to read messages I added cLog as well and added a route from cMessagingEndpoint to cLog
I started the job
on RabbitMQ Management Console I inserted a new message to the respective exchange "myExchangeName" and the message ended in the queue "myQueue"

The problem. Nothing happens. The message is still in the queue. cLog doesn't show anything.
What did I do wrong?
Kind regards,
ORo
Labels (2)
5 Replies
ORo1
Contributor
Contributor
Author

Hi all,
problem solved. I've tested the access with different protocols like MQTT. And it worked like a charm. That was the point as I assume that the problem wasn't Talend or RabbitMQ but the required and provided parameter.
With the correct parameter in cMessaingEndpoint which must be identically to the RabbitMQ Exchange and Queue setup I can get messages via AMQP 0.9 from RabbitMQ.
Kind regards
ORo
Anonymous
Not applicable

Hello,
What is your endpoint URI for the MQTT protocol ?
Thanks
Alex
Anonymous
Not applicable

Hi, I also want to read the message from RabbitMQ. Can you please help here. How you achieved it. What are setting you did.

Anonymous
Not applicable

Hi, Could you please help me for the same. As I am not able to consume message from RabbitMQ

Anonymous
Not applicable

hi Vaibhav,

 

you can go to the rabitMQ console from browser and see what are the setting are used and corresponding parameter you have to set. I was able to consume the msg from rabbitMQ,

 

"rabbitmq://"+context.hostname+":"+context.port+"/"+context.exchangeName+"?vhost="+context.vhostName+"&username="+context.username+"&password="+context.password+"&exchangeType="+context.exchangeType+"&autoDelete="+context.autoDelete+"&queue="+context.queueName+"&routingKey="+context.routingKey

 

i used above string in cMessagingEndPoint component. you have to add rabbitmq parameter as I added above (autoDelete)

 

if accept the solution if you are satisfied with solution.