[AMQ-5400] Unable to keep message order using ActiveMQ-RAR

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 5.9.0, 5.10.0
• Fix Version/s: 5.12.0

Environment

JBoss EAP6 + ActiveMQ 5.10.0

• Patch Info: Patch Available
• Assignee: Gary Tully
• Reporter: Tamas Cserveny
• Created: 17/Oct/14 13:47
• Updated: 16/Jul/15 11:40
• Resolved: 16/Jul/15 11:40

Description

We have an application server which processes the messages using an MDB. We are using message grouping to keep the message processing order.

It seems that it is not possible to do this, because in case the onMessage signals rollback, then the queue does not block until the redelivery time, but keeps on dispatching.

ActiveMQSession.java method afterRollback() @938 is triggered in this case. Which will redeliver the message by scheduling it:

connection.getScheduler().executeAfterDelay(new Runnable() {

@Override
public void run()

{ ((ActiveMQDispatcher)md.getConsumer()).dispatch(md); }

}, redeliveryDelay);

The session is not blocked or otherwise stopped from processing more messages, so it does it.

Setting prefetch=1 for the consumer did not helped.
I have maxSessions=1 in the activationSpec.