Four Stars

Create a message on RabbitMQ using cMessagingEndPoint

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 !

 

2018-04-30_2020.png

 

 

5 REPLIES
Twelve Stars

Re: Create a message on RabbitMQ using cMessagingEndPoint


@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? Smiley Happy

 

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

https://community.talend.com/t5/Design-and-Development/RabbitMQ-pub-sub-pattern-using-cMQConnectionF...

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

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

it just top from google Smiley Happy

-----------
Four Stars

Re: Create a message on RabbitMQ using cMessagingEndPoint

Hi @vapukov

 

thanks for your answer Smiley Happy

 

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

 

 

 

 

 

Twelve Stars

Re: Create a message on RabbitMQ using cMessagingEndPoint

think You miss from - https://community.talend.com/t5/Design-and-Development/RabbitMQ-pub-sub-pattern-using-cMQConnectionF...

 

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

 

 

-----------
Four Stars

Re: Create a message on RabbitMQ using cMessagingEndPoint

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

 

2018-05-14_1837.png

 

Four Stars

Re: Create a message on RabbitMQ using cMessagingEndPoint

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

 

2018-05-22_1825.png

 

 

Thanks a lot for your time