activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Egor Kalinin <m...@ekalinin.com>
Subject [ActiveMQ Artemis]: Message Groups; STOMP; idle consumers
Date Thu, 21 Feb 2019 17:32:40 GMT
Good day,

Protocol: STOMP
auto-create-queues, auto-create-addresses

Steps to reproduce:
1. Run two consumers which subscribe to the `test` queue ['ack': 'client',
'subscription-type': 'ANYCAST'] which are in the infinite loop take a
message from a queue, wait for 1 second and then send ACK.
2. Put 100 messages into the `test` queue ['JMSXGroupID': 'user-1',
'destination-type': 'ANYCAST']
3. Put 1 message into the `test` queue ['JMSXGroupID': 'user-2',
'destination-type': 'ANYCAST']

Expected behavior:
1. `Consumer 1` starts handling [group: user-1] immediately
2. `Consumer 2` starts handling [group: user-2] immediately

Actual behavior:
1. `Consumer 1` starts handling [group: user-1] immediately
2. `Consumer 2` waits until `Consumer 1` handled about 60 - 65 messages and
only after that starts handling [group: user-2]
(The only way to achieve expected behavior was to increase the priority of
the message in [group: user-2])

Can be reproduced even with 3 consumers, 3 message groups with 100 messages
in it (in this case `consumer 3` waits until `consumer 2` handled about 60
- 65 messages.

Please advise.

Regards,
Egor

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