You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@activemq.apache.org by John Lilley <jo...@redpointglobal.com.INVALID> on 2022/09/29 22:11:24 UTC

Disabling prefetch

Related to my previous post (“Processing only one message”), under AMQ 5 I’ve had to disable prefetch to prevent a  “batch server” from hogging messages for a while until it is done and closes the consumer/session (at which point the un-ACKed messages are delivered to other servers).  This was done by decorating the queue name:
if (disablePrefetch) {
   // See https://activemq.apache.org/what-is-the-prefetch-limit-for
   queueName = queueName + "?consumer.prefetchSize=1";
}

I am unsure, but I suspect this approach doesn’t work for Artemis.  What should I do instead?  Or maybe the answer to my previous post will make this moot.

Thanks
john


[rg] <https://www.redpointglobal.com/>

John Lilley

Chief Architect, Redpoint Global Inc.

888 Worcester Street, Suite 200 Wellesley, MA 02482

M: +1 7209385761<tel:+1%207209385761> | john.lilley@redpointglobal.com<ma...@redpointglobal.com>

PLEASE NOTE: This e-mail from Redpoint Global Inc. (“Redpoint”) is confidential and is intended solely for the use of the individual(s) to whom it is addressed. If you believe you received this e-mail in error, please notify the sender immediately, delete the e-mail from your computer and do not copy, print or disclose it to anyone else. If you properly received this e-mail as a customer, partner or vendor of Redpoint, you should maintain its contents in confidence subject to the terms and conditions of your agreement(s) with Redpoint.

Re: Disabling prefetch

Posted by Justin Bertram <jb...@apache.org>.

As Clebert mentioned you should set consumerWindowSize=0, but you'd do that
on the connection URL (e.g. tcp://localhost:61616?consumerWindowSize=0)
rather than when you create the queue. More details are available in the
documentation [1].


Justin

[1]
https://activemq.apache.org/components/artemis/documentation/latest/flow-control.html

On Thu, Sep 29, 2022 at 5:12 PM John Lilley
<jo...@redpointglobal.com.invalid> wrote:

> Related to my previous post (“Processing only one message”), under AMQ 5
> I’ve had to disable prefetch to prevent a  “batch server” from hogging
> messages for a while until it is done and closes the consumer/session (at
> which point the un-ACKed messages are delivered to other servers).  This
> was done by decorating the queue name:
>
> *if *(*disablePrefetch*) {
>
> *// See https://activemq.apache.org/what-is-the-prefetch-limit-for
> <https://activemq.apache.org/what-is-the-prefetch-limit-for>    *queueName
> = queueName + *"?consumer.prefetchSize=1"*;
> }
>
>
>
> I am unsure, but I suspect this approach doesn’t work for Artemis.  What
> should I do instead?  Or maybe the answer to my previous post will make
> this moot.
>
>
>
> Thanks
>
> john
>
> [image: rg] <https://www.redpointglobal.com/>
>
> John Lilley
>
> Chief Architect, Redpoint Global Inc.
>
> 888 Worcester Street, Suite 200 Wellesley, MA 02482
>
> *M: *+1 7209385761 <+1%207209385761> | john.lilley@redpointglobal.com
>
> PLEASE NOTE: This e-mail from Redpoint Global Inc. (“Redpoint”) is
> confidential and is intended solely for the use of the individual(s) to
> whom it is addressed. If you believe you received this e-mail in error,
> please notify the sender immediately, delete the e-mail from your computer
> and do not copy, print or disclose it to anyone else. If you properly
> received this e-mail as a customer, partner or vendor of Redpoint, you
> should maintain its contents in confidence subject to the terms and
> conditions of your agreement(s) with Redpoint.
>