ActiveMQ clients have a prefetch buffer. Try setting the prefetch
buffer to 0 or 1.

You can find details about that on the AMQ site.
http://activemq.apache.org/what-is-the-prefetch-limit-for.html
http://activemq.apache.org/i-do-not-receive-messages-in-my-second-consumer.html

A tip is to type prefetch in the search box on the AMQ front page
website and check the links.


On Tue, Aug 6, 2013 at 9:29 AM, kiranreddykasa <kirankuma...@fss.co.in> wrote:
> Hi
>
> I'm trying to implement camel-activemq.
>
> Here is the route :
>
>         from("netty:tcp://0.0.0.0:7000?textline=true")
>                                 .bean(MainProcessor.class)
>
> .to("activemq:CAMEL_ONE_QUEUE?testConnectionOnStartup=true&replyTo=CAMEL_ONE_QUEUE_REP&replyToType=Exclusive&concurrentConsumers=100&maxConcurrentConsumers=200")
>                                 .choice()
>                                         
> .when(body().not(body().endsWith('F')))
>                                         .otherwise().stop()
>                                     .end()
>
> .to("activemq:CAMEL_TWO_QUEUE?testConnectionOnStartup=true&replyTo=CAMEL_TWO_QUEUE_REP&replyToType=Exclusive&concurrentConsumers=100&maxConcurrentConsumers=200&destination.consumer.prefetchSize=1")
>                                 .choice()
>                                         
> .when(body().not(body().endsWith('F')))
>                                         .otherwise().stop()
>                                         .end()
>
> .to("activemq:CAMEL_THREE_QUEUE?testConnectionOnStartup=true&replyTo=CAMEL_THREE_QUEUE_REP&replyToType=Exclusive&concurrentConsumers=100&maxConcurrentConsumers=200&destination.consumer.prefetchSize=1");
>
>
> I have deployed this same route in two servers .
> I have installed activemq in single server (first server).
>
> And upfront I have load balancer ,sending messages in roundrobin.
>
> Whenever I'm sending messages to server 1 , messages are processing
> properly, but when I'm sending messages to second server no one is picking
> up that messages from first queue and default timeout is happening.
>
> Second server is also using the same activemq which is installed in the
> first server.
>
> camel version : 2.10.5
> activemq : 5.8
>
>
>
> -----
> Regards
>
> kiran Reddy
> --
> View this message in context: 
> http://camel.465427.n5.nabble.com/camel-Activemq-strange-behaviour-tp5736812.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-----------------
Red Hat, Inc.
Email: cib...@redhat.com
Twitter: davsclaus
Blog: http://davsclaus.com
Author of Camel in Action: http://www.manning.com/ibsen

Reply via email to