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

Announcements
Qlik Open Lakehouse is Now Generally Available! Discover the key highlights and partner resources here.
cancel
Showing results for 
Search instead for 
Did you mean: 
Anonymous
Not applicable

ESB : Route consuming messages from RabbitMQ

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 :

 

0683p000009LrkI.pngESB 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

Labels (2)
3 Replies
Anonymous
Not applicable
Author

Hello,

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

Best regards

Sabrina

Anonymous
Not applicable
Author

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
Anonymous
Not applicable
Author

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