Hi Rob,
Thanks for looking at this. We'll probably continue using single-queue
consumers for now then, since the fair behavior is important to us, and try
using multiple-queue consumers again when the new threading model is
available.
Thanks,
Helen
On Tue, Jan 20, 2015 at 10:32 AM, Rob Godfrey
Hi Helen,
apologies for taking so long to respond
On 6 January 2015 at 02:12, Helen Kwong wrote:
> Hi Rob,
>
> I finally got back to testing multiple queues on a consumer again, using
> the changes you added to help with fairness. My broker jvm is running with
> -Dqueue.maxAsynchronousDeliverie
Hi Rob, not sure if you saw my email earlier; would appreciate your help on
this. Thank you!
On Mon, Jan 5, 2015 at 5:12 PM, Helen Kwong wrote:
> Hi Rob,
>
> I finally got back to testing multiple queues on a consumer again, using
> the changes you added to help with fairness. My broker jvm is r
Hi Rob,
I finally got back to testing multiple queues on a consumer again, using
the changes you added to help with fairness. My broker jvm is running with
-Dqueue.maxAsynchronousDeliveries=1 for the number of messages delivered
per time slice by a queue. It has made things more fair than before,
Thanks a lot for the changes and the explanation! Will try this workaround
for now. When the new queue threading model is available please let me know.
On Fri, Oct 31, 2014 at 6:38 AM, Rob Godfrey
wrote:
> Hi Helen,
>
> so the fundamental issue here is that currently inside the broker queues
> "
Hi Helen,
so the fundamental issue here is that currently inside the broker queues
"push" messages to consumers rather than consumers pulling from queues.
When a queue is informed that a consumer has room to accept more messages,
it immediately tries to start pump messages to that consumer. In th
Hi Rob,
I got around to doing some testing on the multi-queue consumer feature you
added. So far things have looked good mostly, but there is one issue I've
run into and would like your help on.
When we had single-queue consumers, we had fair allocation behavior across
queues, in the sense that i
