You could just specify the concurrent consumers in the URIs
from("activemq:queue:foo.bar?concurrentConsumers=7")....
For more see
http://activemq.apache.org/camel/jms.html
On 18/12/2007, shineOnYou <[EMAIL PROTECTED]> wrote:
>
> Hi everyone,
> can anyone please explain how to create concurrent consumer(asynchronous)
> for different queues.
>
> Following is my scenario :
> camelContext.addRoutes(new RouteBuilder() {
> public void configure() {
> // set up a listener on the component
>
> from("activemq:queue:ada.q").choice().when(header("headerName").isEqualTo("widget")).to("activemq:queue:bda.q")
>
> .when(header("headerName").isEqualTo("gadget")).to("activemq:queue:cda.q")
> .otherwise().to("activemq:queue:dda.q");
> from("activemq:queue:ada.q").process(new EventDrivenConsumer());
> from("activemq:queue:bda.q").process(new EventDrivenConsumer());
> from("activemq:queue:dda.q").process(new EventDrivenConsumer());
> }
> });
>
> Above, i want to assign :
> 9 consumer threads to queue "ada.q"
> 7 consumer threads to queue "ada.q"
> 5 consumer threads to queue "cda.q"
> 3 consumer threads to queue "ddda.q"
>
> I tried to use JmsConfiguration class and set the no of concurrent consumer
> but these threads are being created only for first queue "ada.q" and for
> remaining queue only one consumers are created.
> Thanks
> --
> View this message in context:
> http://www.nabble.com/creating-concurrent-consumer-on-each-queue-tp14396321s22882p14396321.html
> Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
--
James
-------
http://macstrac.blogspot.com/
Open Source Integration
http://open.iona.com
