Gentleman,
I will need your help.
I have a use case where I would like to guarantee "consumer affinity",
which is usually implemented using the JMSXGroupID (actually, I am sure it
was working w/ AMQP 0.10 clients but here I am using AMQP 1.0)
My test does the "classical" case:
for (i ... i < 100.)
Message textMsg = new TextM....
textMsg.setStringProperty("JMSXGroupID", "groupA")
MessageProducer.send(textMsg);
and I start two consumers (assuming only one would work).
What I observe is that both consumers are receiving messages, acting as
competing consumers. I also tried added the qpid.group_header_key property
to the queue but it does not change anything.
My setup is
- java broker 6.0.4 & 6.1.4
- java clients using qpid-jms 0.25.0 (AMQP 1.0)
Is this the expected behaviour? Any ideas?
Complementary question: let's assume now, that there is the DR between the
broker & the consumers. Does the DR "propagate" or support "grouping
messages"? (I assume it is depending if you route the link or messages)
thanks for your help
Regards.
