topic How to schedule JMS consuming in a Talend route ? in Talend Studio

How to schedule JMS consuming in a Talend route ?

Loko — Sat, 16 Nov 2024 06:54:18 GMT

I need to use an ActiveMQ queue as cache to store all the messages of the day, then process them at 9pm.

In Talend ESB, how can we schedule queue consuming ? I can't see any Camel option for cJms like the ones for file:// or ftp:// messaging endpoints.

Re: How to schedule JMS consuming in a Talend route ?

vapukov — Fri, 11 Jan 2019 11:33:36 GMT

for consumer, I don't know the way to schedule it (as a variant - disable/enable route by schedule)

but why you need a route for parse messages? it is a simple task for normal DI Job, then you can schedule this job as you want

Re: How to schedule JMS consuming in a Talend route ?

Loko — Fri, 11 Jan 2019 12:14:54 GMT

But we don''t need nore use DataIntegration and jobs.

We use with Talend ESB and it works fine.

Re: How to schedule JMS consuming in a Talend route ?

vapukov — Fri, 11 Jan 2019 12:50:57 GMT

@Loko wrote:

We use with Talend ESB and it works fine.

if it does not cover all your needs - at least you have 100% working solution

you already have Studio for ESB, it already support DI perspective, so all what you need - is build standalone job and deploy it.

of course if would be direct solution for scheduling consumer - it will be interesting to know

Re: How to schedule JMS consuming in a Talend route ?

Loko — Fri, 11 Jan 2019 13:45:55 GMT

I don't need a job to parse messages. I can do it very easily with a Camel route. And mixing routes and jobs is a really bad idea because of lacks of performance, Talend said.

Please keep in my purpose : scheduling JMS consuming. I don't need help for parsings messages, I've been doing it for years now.

Thank you 😕

Re: How to schedule JMS consuming in a Talend route ?

vapukov — Fri, 11 Jan 2019 13:49:50 GMT

@Loko wrote:

Thank you 😕

you are welcome 😉

Re: How to schedule JMS consuming in a Talend route ?

Loko — Fri, 25 Jan 2019 15:33:21 GMT

I got the solution : in a cProperty define a RoutePolicy java objet

In a DSL component use it into the route flow, it can't be set a start component but will work anyway from the very beggening of the route instance.