Hi,
I'm back with a new question about ActiveMQ :)
My configuration is the following :
* Message Group enabled with 5000 different groups
* 2 ActiveMQ brokers installed in a Network of Broker with KahaDb
persistence enabled
* I consume these message thought the Spring's
DefaultMessageListenerContainer & the ActiveMQ's
PooledConnectionFactory though 5 JVM instance with 15 thread each
I've got an issue that appear sometime and randomly, here a description
below :
* Let's defined Consumer1 a consuming thread that own a message group
(Group1) that have for example an average time of 30s to consume a
message (for information, other groups took 5s in average time to
consume a message and have less messages sended).
* Consumer1 had consumed some message of Group1 (let's say about 50),
It receives a new Group1's message (Message1), and then begin to
consume it.
* But, the same Message1 is sent on an other consumer thread
(Consumer2), and then Group1 is relocated on Consumer2 (because all
next Group1's message, will be consumed by Consumer2).
This is annoying, because I don't want to have Message1 consumed at the
same time Consumer1 and Consumer2. It's hard to replay because, it
happened randomly.
Have you got an idea about what could generate this comportment and how
to change it ?
Best,
Jérôme
