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.
