how to run multiple routes at the same time

Anonymous — Sat, 16 Nov 2024 10:56:33 GMT

Hi,
i have a route job with cHttp component as input and followed by two cTalenjob components.
i want to use one http request to run this two cTalendjob at the same time. The request uri will hold two variables, and each will be pass to one cTalendjob.
how can i run the multiple routes at the same time?
The attached is my sample, which the second routes got an error.

Re: how to run multiple routes at the same time

Anonymous — Thu, 19 Nov 2015 12:51:49 GMT

use the cMulticast component to run two cTalendJobs on separate threads.

Re: how to run multiple routes at the same time

Anonymous — Thu, 19 Nov 2015 22:50:47 GMT

Hi, eost,
Thanks a lot. It works on my job.Here, i attached the job image. there is another " org.apache.camel.component.direct.DirectConsumerNotAvailableException" on http client ,could you help with some more details?
Here is my setting information.
a)two variables in http uri. They are headFileName and detailFileName.
b)set cMulticast component with two uris rows. The first one is "direct:headFileName", the second one is "direct:detailFileName"
c)set cMessagingEndPoint uri with ""direct:headFileName" and "direct:detailFileName" respectively
d)the cTalendjob will use propagate context.

The exception detail is on below.
org.apache.camel.component.direct.DirectConsumerNotAvailableException: No consumers available on endpoint: Endpoint. Exchange]
at org.apache.camel.component.direct.DirectProducer.process(DirectProducer.java:47)
at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:129)
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91)
at routines.system.CamelStat$1$1.process(CamelStat.java:56)
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:448)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:652)
at org.apache.camel.processor.MulticastProcessor.doProcessSequential(MulticastProcessor.java:580)
at org.apache.camel.processor.MulticastProcessor.process(MulticastProcessor.java:227)
at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91)
at routines.system.CamelStat$1$1.process(CamelStat.java:56)
at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:91)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)
at org.apache.camel.component.jetty.CamelContinuationServlet.service(CamelContinuationServlet.java:162)
at javax.servlet.http.HttpServlet.service(HttpServlet.java:848)
at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:686)
at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1494)
at org.eclipse.jetty.servlets.MultiPartFilter.doFilter(MultiPartFilter.java:136)
at org.apache.camel.component.jetty.CamelFilterWrapper.doFilter(CamelFilterWrapper.java:43)
at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1465)
at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:499)
at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1086)
at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:428)
at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1020)
at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:135)
at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:116)
at org.eclipse.jetty.server.Server.handle(Server.java:370)
at org.eclipse.jetty.server.AbstractHttpConnection.handleRequest(AbstractHttpConnection.java:489)
at org.eclipse.jetty.server.AbstractHttpConnection.headerComplete(AbstractHttpConnection.java:949)
at org.eclipse.jetty.server.AbstractHttpConnection$RequestHandler.headerComplete(AbstractHttpConnection.java:1011)
at org.eclipse.jetty.http.HttpParser.parseNext(HttpParser.java:644)
at org.eclipse.jetty.http.HttpParser.parseAvailable(HttpParser.java:235)
at org.eclipse.jetty.server.AsyncHttpConnection.handle(AsyncHttpConnection.java:82)
at org.eclipse.jetty.io.nio.SelectChannelEndPoint.handle(SelectChannelEndPoint.java:668)
at org.eclipse.jetty.io.nio.SelectChannelEndPoint$1.run(SelectChannelEndPoint.java:52)
at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:608)
at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:543)
at java.lang.Thread.run(Unknown Source)

Re: how to run multiple routes at the same time

Anonymous — Fri, 20 Nov 2015 09:07:42 GMT

Hello orayangy,
You send the message to detailFileName and headFileName, but where are they? You have to use the component cDirect to take over your message in your route.

Re: how to run multiple routes at the same time

Anonymous — Fri, 20 Nov 2015 09:14:30 GMT

Disconnect your two cMessagingEndpoint components from the cMulticast. The multicast should have two URIs ("direct:headFileName" and "direct:detailFileName"). The two cMessagingEndpoints (disconnected) should have the same endpoints (1 for each). The endpoints are basically the "address" that the MessagingEndpoint is sending to.

topic Re: how to run multiple routes at the same time in Talend Studio

how to run multiple routes at the same time

Re: how to run multiple routes at the same time

Re: how to run multiple routes at the same time

Re: how to run multiple routes at the same time

Re: how to run multiple routes at the same time