camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "James Strachan" <james.strac...@gmail.com>
Subject Re: creating concurrent consumer on each queue
Date Tue, 18 Dec 2007 13:23:06 GMT
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 <sanjeet.9211@gmail.com> 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

Mime
View raw message