Clebert, Thank for the reply! I can see how to see this for the connection by adding this to the URL ?consumerWindowSize=0 https://activemq.apache.org/components/artemis/documentation/1.1.0/flow-control.html
I can also call setConsumerWindowSize(0) on the connection factory. Can I set this explicitly on a consumer instance after it is created? 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.lil...@redpointglobal.com<mailto:john.lil...@redpointglobal.com> From: Clebert Suconic <clebert.suco...@gmail.com> Sent: Friday, September 30, 2022 3:02 AM To: users@activemq.apache.org Subject: Re: Processing only one message *** [Caution] This email is from an external source. Please use caution responding, opening attachments or clicking embedded links. *** Look at slow consumers. Set consumer window size to 0 on this consumer. On Thu, Sep 29, 2022 at 6:01 PM John Lilley <john.lil...@redpointglobal.com.invalid<mailto:john.lil...@redpointglobal.com.invalid>> wrote: We have an application that should read a single message from a queue (a “job” queue) and then stop processing more messages. Think of it as a “batch request”. This is entirely using the JMS driver. Is there a good pattern for this? Under ActiveMQ 5, I call consumer.close(), session.close() from onMessage() and that works fine. However, session.close() is not allowed under Artemis (and maybe it was always wrong). I’ve tried calling only consumer.close(), and leave the session open. But the message is not ACked. Explicitly calling message.acknowledge() doesn’t work either, because it gets to >>> and individualAck is false: public void acknowledge() throws JMSException { if (session != null) { try { if (session.isClosed()) { throw ActiveMQClientMessageBundle.BUNDLE.sessionClosed(); } >>> if (individualAck) { message.individualAcknowledge(); } Going back to the original question, what is the recommended pattern for this? Thanks john [rg]<https://linkprotect.cudasvc.com/url?a=https%3a%2f%2fwww.redpointglobal.com%2f&c=E,1,woI5c78_8f-DCJwnBAd2SB8ZQhLpa0H91b89ArK-kwPX0ToGxJQJmAWCo4pKKXorliMxDRxv9bVPLRhLdu50I9WBzrjdu8_-3xSL4nhKhbgAxC-hndfqanIBQp4,&typo=1> John Lilley Chief Architect, Redpoint Global Inc. 888 Worcester Street, Suite 200 Wellesley, MA 02482<https://www.google.com/maps/search/888+Worcester+Street,+Suite+200+Wellesley,+MA+02482?entry=gmail&source=g> M: +1 7209385761<tel:+1%207209385761> | john.lil...@redpointglobal.com<mailto:john.lil...@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. -- Clebert Suconic 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.
