topic Re: Create a message on RabbitMQ using cMessagingEndPoint in Talend Studio

Create a message on RabbitMQ using cMessagingEndPoint

Anonymous — Sat, 16 Nov 2024 08:19:44 GMT

Hello everybody,

I'm beginner on Talend Open Studio for ESB, I'm trying to use the Camel component RabbitMQ with cMessageingEndpoint.

I want to create a message in a specific queue, for the moment, I just create the queue on RabbitMQ, I don't which component I should add in my route to send a new message ...

I didn't find any tutorial or previous message on the forum ...

Thanks a lot !

Re: Create a message on RabbitMQ using cMessagingEndPoint

vapukov — Thu, 03 May 2018 05:40:57 GMT

@remi13wrote:

Hello everybody,

I'm beginner on Talend Open Studio for ESB, I'm trying to use the Camel component RabbitMQ with cMessageingEndpoint.

I want to create a message in a specific queue, for the moment, I just create the queue on RabbitMQ, I don't which component I should add in my route to send a new message ...

I didn't find any tutorial or previous message on the forum ...

Thanks a lot !

Sure?

https://community.talend.com/t5/Design-and-Development/ESB-Route-consuming-messages-from-RabbitMQ/td-p/42510

https://community.talend.com/t5/Design-and-Development/RabbitMQ-pub-sub-pattern-using-cMQConnectionFactory-and-cAMQP/td-p/32419

https://community.talend.com/t5/Design-and-Development/cMessagingEndpoint-and-RabbitMQ-ESB-Mediation/td-p/89267

https://help.talend.com/reader/YtJvt25ynUgZ~sfL~L5dAg/~Frg0sDUnO_FZaY27Y4GVg

it just top from google

Re: Create a message on RabbitMQ using cMessagingEndPoint

Anonymous — Thu, 03 May 2018 08:43:42 GMT

Hi @vapukov

thanks for your answer

I already read those help topic/tutorials but I read that it's better/more appropriate to use the cMessagingEndpoint to exchange with RabbitMQ. Maybe it's just the way to read message from RabbitMQ and not to send message ?

Maybe I should use the cAMQP to send message ? I tried it and getting an other error as you can see in attachment.

the cMQConnectionFactory is configured with

AMQP1.0 (I have activated the plugin 1.0 on my RabbitServer)
my IP
Port : 5672
auth : my login/pass

The cSetBody is a "simple" type, with "Hello World"

I hope you can help

Thanks a lot for your time

3.png
2.png
1.png

Re: Create a message on RabbitMQ using cMessagingEndPoint

vapukov — Fri, 04 May 2018 01:02:43 GMT

think You miss from - https://community.talend.com/t5/Design-and-Development/RabbitMQ-pub-sub-pattern-using-cMQConnectionFactory-and-cAMQP/td-p/32419

it very critical for properties, like - durable, auto-delete and etc
by default from Talend it come - both false, and if on Server side any of them enabled - Talend can not connect to server

it work with both variants, but You must mange Your settings:

- from RabbitMQ side - check properties for Exchange/Queue
- from Talend Side - use Advanced settings for add specific properties

P.S. Start from simple case:
- create exchange - Direct/Transiting
- create queue - Transiten/Auto-delete None
- bind queue to exchange
- test
it should work
then start play with settings

Re: Create a message on RabbitMQ using cMessagingEndPoint

Anonymous — Mon, 14 May 2018 17:40:08 GMT

Hi @vapukov

Sorry for the late answer, i was on vacation. I'm sorry, i still do not understand. I gave up using :

cTimer - CsetBody - cAMQP - cLog

It wasnt working.

here is my actual Job, you can see the properties. It create the Queue (persistant).

I still dont understand how to set up the message to push in the queue ...

Thanks again for your help

Re: Create a message on RabbitMQ using cMessagingEndPoint

Anonymous — Tue, 22 May 2018 17:23:56 GMT

Hello

any chance you can help me ? Here is my job, I want to change the setbody "Hello world" with a JSON to send as message in the queue

Thanks a lot for your time

Re: Create a message on RabbitMQ using cMessagingEndPoint

Anonymous — Thu, 24 Jan 2019 12:44:04 GMT

Hy remi13,

if you want to send a JSON in the cSetBody element, I guess, you can put just the json value in the expression field. See below the first image and after you can see the log, how value appears in the message:

Anyway, this camel component is a little bit tricky, if you want to send or you want to recieve messages. My experience is: if this -cMessagingEndpoint- component is the first componenet in one of your route, the this componenet acts like a message consumer >> cMessagingEndpoint-cLog. If this component not the first and there is a message create componenet before, it acts like a message sender >> cTimer-cSetBody-cMessagingEndpoint.

Best regards
Viktor

Re: Create a message on RabbitMQ using cMessagingEndPoint

Anonymous — Thu, 24 Jan 2019 13:40:33 GMT

Hello

thansk a lot for your answer. We made an API and call it from Talend to add the message in queue.

Your solution seems to be ok, we already tried it but it was not possible to get the content of the message from an other component. I mean, we would like to get the message in setBody from a CSV for example.

Do you know how to do that ?

Re: Create a message on RabbitMQ using cMessagingEndPoint

Anonymous — Thu, 24 Jan 2019 15:04:46 GMT

Try to use Simple language and the expression: "${in.body}". I could read the file content in the message payload.

You can read more about simple language here. There are some useful variable, you can access more things.

Hope this helps!

Viktor

Re: Create a message on RabbitMQ using cMessagingEndPoint

Anonymous — Thu, 24 Jan 2019 18:38:29 GMT

thanks for your reply , i will try that !

Re: Create a message on RabbitMQ using cMessagingEndPoint

Loko — Fri, 25 Jan 2019 15:13:35 GMT

Ummh... no need to use a cSetBody component and give it the in.body property : it does ... nothing !

The cFile or cMessagingEndpoint components already put the file content into the message body.