Internal property on the consumer I meant. On Fri, Sep 30, 2022 at 9:01 PM Clebert Suconic <clebert.suco...@gmail.com> wrote:
> > I don’t think you can do that. That’s a property for the session afaik. > If you see an internal property with that name be careful as I’m not aware > of any tests. > > > On Fri, Sep 30, 2022 at 4:16 PM John Lilley > <john.lil...@redpointglobal.com.invalid> wrote: > >> 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 >> >> >> >> >> [image: rg] <https://www.redpointglobal.com/> >> >> 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 <+1%207209385761> | 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> 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 >> >> >> >> [image: 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 <+1%207209385761> | 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. >> > -- > Clebert Suconic > -- Clebert Suconic
