activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Takawale, Pankaj" <pankaj.takaw...@dowjones.com>
Subject Re: Message Group rebalancing
Date Mon, 16 Nov 2015 17:38:23 GMT
You could achieve it from your application logic. You could have your
producer or consumers break the JMSXGroupID stickiness by sending
JMSXGroupSeq=-1
message after producing or receiving N messages from the same groupID.
After stickiness break up, new consumers would get a chance to acquire the
groups.



On Wed, Nov 11, 2015 at 9:49 AM, Rob Davies <rajdavies@gmail.com> wrote:

> Nice feature - submit a JIRA!
>
> > On 11 Nov 2015, at 14:28, Tim Bain <tbain@alumni.duke.edu> wrote:
> >
> > I've never heard of such a feature (but maybe someone else here has),
> but I
> > think it would be a great addition if it doesn't exist.  So if you don't
> > get a response within a couple days, I encourage you to submit an
> > enhancement request in JIRA.
> >
> > Tim
> > On Nov 10, 2015 2:20 PM, "sspind" <sspind@yandex.com> wrote:
> >
> >> Hi there,
> >>
> >> a question related to message groups: is it possible to rebalance
> message
> >> groups when a new consumer registers with the broker?
> >> In my setup I have two consumers that consume from the same queue where
> all
> >> messages have a message group ID. If one consumer loses connection all
> >> messages go to the other. If the consumer reconnects messages will
> still go
> >> to the other one. At least if the broker saw the respective group ID
> >> already. I know that new messages will again be given to either of the
> >> consumers. However, in my scenario there is only a relatively small set
> of
> >> "long lived" group IDs. So it can happen that all messages will be
> routed
> >> to
> >> one consumer while the other one is idle.
> >>
> >> Looking forward to your replies!
> >>
> >> sspind
> >>
> >>
> >>
> >> --
> >> View this message in context:
> >>
> http://activemq.2283324.n4.nabble.com/Message-Group-rebalancing-tp4703823.html
> >> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
> >>
>
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message