Thanks for pointing out, it was missing <redistribution-delay>10</redistribution-delay>
Thanks Again, Prateek Jain -------------------------------------------------------------- EXPECTATION : Causes all troubles...... -------------------------------------------------------------- On Mon, Mar 6, 2023 at 7:36 PM Justin Bertram <jbert...@apache.org> wrote: > The use-case you're describing is exactly the use-case that message > redistribution solves. This is different from what the documentation calls > "initial distribution" which is working properly according to your previous > explanation. > > Can you confirm you read the documentation I linked previously? What value > do you have configured for the redistribution-delay address-setting? > > The broker ships with an example to demonstrate how redistribution works. > It's in the examples/features/clustered/queue-message-redistribution > directory in the broker distribution. > > > Justin > > On Mon, Mar 6, 2023 at 1:22 PM prateekjai...@gmail.com < > prateekjai...@gmail.com> wrote: > > > Hi Justin, > > > > Thanks for responding. Yes, message redistribution is configured and it > is > > working fine. The issue occurs when, producer is done with sending > messages > > but *no consumer is up till then*. Now, when a consumer comes up; it only > > gets messages that are present on that particular node only (node to > which > > consumer is connected) . Ideally, I would expect that all messages on > that > > particular queue (from other nodes too) should be delivered to that > > consumer. Any idea, what is missing here. > > > > Note: Everything works fine if the consumer is up and running when the > > producer is sending messages. > > > > Regards, > > Prateek Jain > > > > > > On Mon, Mar 6, 2023 at 6:44 PM Justin Bertram <jbert...@apache.org> > wrote: > > > > > It sounds like you need to configure message redistribution [1]. Have > you > > > done that? > > > > > > > > > Justin > > > > > > [1] > > > > > > > > > https://activemq.apache.org/components/artemis/documentation/latest/clusters.html#message-redistribution > > > > > > On Mon, Mar 6, 2023 at 12:17 PM prateekjai...@gmail.com < > > > prateekjai...@gmail.com> wrote: > > > > > > > Hi All, > > > > > > > > I am facing an issue where, I have created a 3 node cluster of > artemis > > > and > > > > created a distributed queue on it, for example exampleQueue. > > > > > > > > When I send messages to this queue, messages are loadbalanced on each > > > node. > > > > If there is a consumer already listening/connected to any node in > > cluster > > > > for this queue, it receives all those messages (This is working > fine). > > > > > > > > The problem starts if there is no consumer to this queue connected > to > > > any > > > > node. Then, when a consumer comes up and connects to a node, it only > > > > receives messages present on that particular node only. Is it > possible > > to > > > > divert all unread messages to this consumer? Any ideas? > > > > > > > > Regards, > > > > Prateek Jain > > > > > > > > > >
