topic Re: cMessagingEndpoint and RabbitMQ (ESB Mediation) in Talend Studio

cMessagingEndpoint and RabbitMQ (ESB Mediation)

ORo1 — Sat, 16 Nov 2024 10:48:21 GMT

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

Re: cMessagingEndpoint and RabbitMQ (ESB Mediation)

ORo1 — Mon, 15 Feb 2016 16:45:03 GMT

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

Re: cMessagingEndpoint and RabbitMQ (ESB Mediation)

Anonymous — Wed, 20 Jun 2018 07:34:51 GMT

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

Re: cMessagingEndpoint and RabbitMQ (ESB Mediation)

Anonymous — Thu, 01 Nov 2018 21:37:30 GMT

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

Re: cMessagingEndpoint and RabbitMQ (ESB Mediation)

Anonymous — Tue, 09 Jul 2019 21:33:54 GMT

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

Re: cMessagingEndpoint and RabbitMQ (ESB Mediation)

Anonymous — Fri, 26 Jul 2019 23:12:42 GMT

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.