camel-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <>
Subject Re: Problems in implementing Loadbalance using ActiveMQ and Camel
Date Sat, 28 Feb 2009 10:15:39 GMT

On Thu, Feb 26, 2009 at 11:05 PM, dasalav <> wrote:
> Hi
> My requirement is:
>  i have an input queue of Active MQ 5.1.  the messages keeps adding to it.
> These messages are to be consumed by 3 differerent consumers. But  each
> consumer queue  should have a limit to 2. If the consumer queue is full,
> the producer should stop sending messages to that queue and proceed with the
> others.
> I am trying to implement this functionality using round robin of Camel 1.5
> like this.
> from(fromDest).loadBalance().roundRobin().to(loadbal1,loadbal2,loadbal3);
> Note:
> I haven't found any source to limit the size of consumer queue.
> Please help me.
A consumer queue only allowing 2 elements is a really harsh SLA. Why
cant it be higher? Whats the reason?

You need some kind of producer to these queue that can try to put it,
and if it fails it will try the next queue in a round robin fashion or
some other algorithm.

When you try today to put on a full queue do you get a rejection or
does it block until there is room?
I am wondering how this is supported by JMS. Have you tried asking at
the ActiveMQ forum as well?

> Thanks in advance.
> --
> View this message in context:
> Sent from the Camel - Development (activemq) mailing list archive at

Claus Ibsen
Apache Camel Committer

Open Source Integration:

View raw message