Hi Sergey,
On 13 March 2014 11:02, Sergey Mashkov <[email protected]> wrote: > Hi all > > I am experiencing strange behaviour. I have one non durable queue and two > consumers. And message grouping is configured for the queue. I also have > one > producer that works faster that consumers can handle messages so queue > could > became big. > > At first message grouping works properly and both consumer handles > messages. > However if I stop first one then the second consumer continues working. > When > I start first consumer back then it connects but consumes nothing so > balancing doesn't work any more. Even with pre-fetch size = 1. If I stop > second consumer then the first will work. But there is no way to make them > both handle messages as they does before consumer restart. > > Am I missing something? What options do I have? > How are you dividing your messages into groups? If you only have a small, fixed number of groups then it's possible that while the second consumer is disconnected, all groups are being associated with the first consumer. As per http://qpid.apache.org/releases/qpid-trunk/java-broker/book/Java-Broker-Queues.html#Java-Broker-Queues-OtherTypes-BrokerRoleunless you are using the "shared groups"mode the assignment of group to consumer stays for the lifetime of the consumer (but no longer). If all you are looking for is to ensure that no group is being is being concurrently processed by two consumers then the shared group mode will do that but will not mean that a given group is tied to a consumer until that consumer disconnects. -- Rob > > Thanks and kind regards > Sergey Mashkov > > > > -- > View this message in context: > http://qpid.2158936.n2.nabble.com/qpid-Java-broker-and-message-grouping-tp7605546.html > Sent from the Apache Qpid users mailing list archive at Nabble.com. > > --------------------------------------------------------------------- > To unsubscribe, e-mail: [email protected] > For additional commands, e-mail: [email protected] > >
