Thanks a lot mr. O'Day for the correction, and thanks to everyone else for
the time taken to answer my question :-D
--
View this message in context:
http://camel.465427.n5.nabble.com/concurrentConsumers-basic-question-tp4535789p4539262.html
Sent from the Camel - Users mailing list archive at Na
you are getting duplicates because the topic has up to 10 concurrent
consumers based on your jmsConfig...
so should either change the jmsConfig (used by all routes) or explicitly set
these on any routes in question...
from("activemq:topic:xmlOrders?maxConcurrentConsumers=1&concurrentConsumers=1")
If you want multiple consumers on topics you might take a look at virtual
topics.
My guess is that these can have multiple consumers. Correct me if i'm wrong.
/preben
--
View this message in context:
http://camel.465427.n5.nabble.com/concurrentConsumers-basic-question-tp4535789p4536257.html
Sen
You're totally right mr. Travis, just confirmed and also read it on the camel
book
concurrentConsumers
Sets the number of consumer threads to use. It’s a good
idea to increase this for high-volume queues, *but it’s not
advisable to use more than one concurrent consumer for
JMS topics, beca
I'm not 100% on this, so someone correct me if I'm wrong.
* concurrentConsumers should only be set on the "from" part of a route.
using a queue in the "to" part of a route is not actually going to consume
any messages.
* You probably should not use concurrentConsumers at all with a topic. A
topi
thanks for the answer Mr. Pham, I've commented my "concurrent configs" on my
spring file and I've done it the way you propose:
from("activemq:topic:xmlOrders").to("activemq:accounting?concurrentConsumers=5");
Thanks for the advice. However, the activemq:accounting queue is still
getting the m
Hi rogelio,
I think you should not have maxConcurrentConsumers on a connection pool.
What you want may be maxConcurrentConsumers on the activemq consumer like:
from("activemq:topic:xmlOrders").to("activemq:accounting?concurrentConsumers=5");
from("activemq:topic:xmlOrders").to("activemq:production
