You learn something new, every day = ) (well, atleast on a good day ; ) JB: OK! What's the difference between transport.prefetch and consumer.prefetchSize?
BR, - Simon On Tue, 2022-02-08 at 09:50:17 +0100, CASAUX Nicolas wrote: > Hello Simon, > > I tested this and it does NOT work. > As per my understanding, this setting is for the connection string of the > consumer. > > The solution provided by JB works however (using per destination policy). > > Nicolas > > > C2 - Usage restreint > > -----Message d'origine----- > De : Simon Lundström <[email protected]> > Envoyé : mardi 8 février 2022 07:54 > À : [email protected] > Objet : Re: Limit prefetchSize from ActiveMQ side > > [Vous ne recevez pas souvent de courriers de la part de [email protected]. > D?couvrez pourquoi cela peut ?tre important ? l'adresse > http://aka.ms/LearnAboutSenderIdentification.] > > On Mon, 2022-02-07 at 10:37:52 +0100, CASAUX Nicolas wrote: > > Hello, > > > > I'm using ActiveMQ < classic > 5.16.0 and I have a question related to slow > > consumers. > > > > In my use case, I only use topics with non-durable messages. As per the > > doc, the prefetchSize is 32767. > > I have a constantPendingMessageLimitStrategy on this topic with a limit of > > 1000 messages. > > I can observe both values on the webconsole accordingly when they reach the > > limit (I see 32767 messages in the dispatch queue size and 1000 messages in > > the pending queue size) > > > > I have a bunch of slow consumers, which do not set any prefetchSize (hence > > they have the default 32767 value). > > > > My question is: how can I set, change or force this value from ActiveMQ > > side ? > > > > I don't want those consumers to connect without a prefetchSize value, and I > > consider the default value too high for my usecase. > > That's why I would like to reduce this value. > > > > Any hints on this ? > > Thanks! :) > > > > Nicolas > > > > > > C2 - Usage restreint > > I belive you can set the default on your transportConnector, see > https://eur01.safelinks.protection.outlook.com/?url=https%3A%2F%2Factivemq.apache.org%2Fmqtt.html%23message-prefetch&data=04%7C01%7Cnicolas.casaux%40soprasteria.com%7C6a9b7645675546c7873908d9eacfc143%7C8b87af7d86474dc78df45f69a2011bb5%7C0%7C0%7C637799000872157995%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2luMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C3000&sdata=SLM%2Bu3422R1zFeYx7Y285z8DxXR6ZJyXhx6sQ4q09VQ%3D&reserved=0 > > BR, > - Simon
