Hello Matt,
Thanks for your answer. However, I'm not able to reproduce what you suggests or I maybe misunderstood something. Here is my test procedure: If a consumer: 1. subscribes to the queue "Consumer.consumer01.VirtualTopic.invoices" with selector "k1=v1" and ClientID "myClient" 2. disconnects 3. reconnects and subscribes to the queue "Consumer.consumer01.VirtualTopic.invoices" with selector "k1=v2" and ClientID "myClient" Then, the selectors in cache from the logs are: DEBUG | current selectors in cache: [k1='v1', k1='v2'] So, the first selector is never replaced or removed from the cache, and those unwanted message are still being copied to the queue. Is that the expected behavior or am I doing something incorrect ? Thanks in advance Regards, Nicolas -----Message d'origine----- De : Matt Pavlovich <mattr...@gmail.com> Envoyé : lundi 21 octobre 2024 16:57 À : users@activemq.apache.org Objet : Re: VirtualSelectorCacheBrokerPlugin - expiration of selectors ? Hi Nicolas- The selector is cached from first consumer registration until it is replaced by a new consumer registration. The selector is also written to disk so it will become active on broker restart, so there is no loss between broker startup and consume connecting. The selector will be active the entire time it is registered with the broker up until a new selector is provided by a new consumer— in your example, that would be step #3 when the second selector would become active and the first selector is deactivated. Thanks, Matt Pavlovich > On Oct 21, 2024, at 4:58 AM, CASAUX Nicolas <nicolas.cas...@soprasteria.com> > wrote: > > > Hello ! > > I have a question regarding the VirtualSelectorCacheBrokerPlugin > mentioned here : > https://acti/ > vemq.apache.org%2Fcomponents%2Fclassic%2Fdocumentation%2Fvirtual-desti > nations&data=05%7C02%7Cnicolas.casaux%40soprasteria.com%7C68960e1ca7a3 > 45dd52ec08dcf1e0a8f1%7C8b87af7d86474dc78df45f69a2011bb5%7C0%7C0%7C6386 > 51194413219073%7CUnknown%7CTWFpbGZsb3d8eyJWIjoiMC4wLjAwMDAiLCJQIjoiV2l > uMzIiLCJBTiI6Ik1haWwiLCJXVCI6Mn0%3D%7C0%7C%7C%7C&sdata=sGewpjZyGCr%2Bl > fICI8lqAfbHhwXqNTwbb5%2FexKjpDcI%3D&reserved=0 > > If a consumer follows those actions in order: > > 1. subscribes to a queue "Consumer.consumer01.VirtualTopic.invoices" with > selector "k1=v1" > 2. disconnects > 3. reconnects and subscribes to the same queue > "Consumer.consumer01.VirtualTopic.invoices" with a new selector "k2=v2" > > How long will the "k1=v1" condition will be used to forward message from the > topic to the queue ? Will it be forever ? > I could not find such info in the docs, and I was not able to find it > in the code. (I saw the 10 mn scheduler to persist selectors, but it's > another topic) > > Thanks in advance! > > Regards, > Nicolas > > > C2 - Usage restreint --------------------------------------------------------------------- To unsubscribe, e-mail: users-unsubscr...@activemq.apache.org For additional commands, e-mail: users-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact C2 – Usage restreint --------------------------------------------------------------------- To unsubscribe, e-mail: users-unsubscr...@activemq.apache.org For additional commands, e-mail: users-h...@activemq.apache.org For further information, visit: https://activemq.apache.org/contact
