topic ESB : Route consuming messages from RabbitMQ in Talend Studio

ESB : Route consuming messages from RabbitMQ

Anonymous — Sat, 16 Nov 2024 09:03:42 GMT

Hello there,

I'm a beginner in Talend ESB and I would like to simulate a route producing&consuming messages with a queue (local RabbitMQ).

I have developped this route, which does it quite well :

ESB route producing and consuming messagesBut now, I would like to delay the messages delivery.

Explicitly, the main idea would be this :

- I would like that the producer sends many messages to the queue in a short laps of time, (this point is ok)

- While I would like that the consumer recieves messages from the queue slowly : 1 message consumed every minute for example.

I've found this was possible by referring to this link : Scheduling messages with RabbitMQ

However, I'm not able to use it in my route.

The solution might be, in the Camel rabbitmq component, to define the parameter connectionFactory (ref : http://camel.apache.org/rabbitmq.html).

But I'm not even able to do that.

Do some of you have already use RabbitMQ through Talend ESB ?

What about delaying the messages delivery ?

I will appreciate any help to go further.

Thanks in advance.

Kapusch

Re: ESB : Route consuming messages from RabbitMQ

Anonymous — Mon, 20 Nov 2017 02:49:19 GMT

Hello,

Could you please have a look at this TalendHelpCenter:Camel Component: RabbitMQ to see if it is OK with you?

Best regards

Sabrina

Re: ESB : Route consuming messages from RabbitMQ

Anonymous — Mon, 20 Nov 2017 15:25:11 GMT

Hello xdshi,

I have already checked this Help, but haven't found how to define the parameter connectionFactory in the Camel Component through Talend ESB... Any clue for this point ? 😕

Furthermore, do you know something about delaying the messages delivery ?

Cordially,
Kapusch

Re: ESB : Route consuming messages from RabbitMQ

Anonymous — Thu, 24 Jan 2019 13:07:56 GMT

Hy,

did you try the cDelayer component? It makes a delay in the routing flow, so I guess, next message read won't be triggered until the flow before did not finish.
And if you want to get only one message, I guess, this property can help to you: prefetchCount in this docs.

Hope I could help!

Best regards
Viktor