On Tue, Feb 9, 2010 at 1:30 PM, Muhammad Ichsan <[email protected]> wrote: > Dear All > > I have to questions: > 1. How to specify concurrent consumers for queue:oth in > <inOut uri="activemq:inh?replyTo=queue:oth&concurrentConsumers=50"/> > > Because, "concurrentConsumers=50" only applies to queue:inh (as I > see in activemq webadmin console which states only one consumer > listening to queue:oth) I'm considering this is one of the culprits of > my slow app. > > 2. It seems that camel doesn't see a message with the same correlation > id as a response message in <inOut> (IMHO). I have an application > which listens to activemq:inh (see tag in my first question) and put a > response (new message with the same correlation id) into activemq:oth > in a hope that <inOut>'s blocking will end. Although the blocking end, > I still receive Time out exception. Why this happens? >
Google a bit how to do request/reply over JMS. Basically you need 2 queues for that, and that is why you need to use the JMSReplyTo. And check out some of the Camel unit tests how to do that as well. If you need much more help then consider professional support or the likes. > Thanks > > -- > ~The best men are men who benefit to others > http://michsan.web.id > > Yang berkualitas memang beda rasanya! > http://rizqi-cookies.com > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
