[AMQ-6054] Durable subscriber cannot receive the existing messages after AMQ restarts

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Affects Version/s: 5.12.1
• Component/s: Broker

Environment

Redhat Linux

• Assignee: Unassigned
• Reporter: Nevin Chen
• Created: 20/Nov/15 07:24
• Updated: 24/Nov/15 02:17
• Resolved: 24/Nov/15 02:17

Description

How to Reproduce
1. Make a durable subscription to a topic from a JMS client.
2. Disconnect the JMS client.
3. Send a message to the subscribed topic from another JMS client.
4. Restart AMQ.
5. When the duarable re-connects to AMQ, it cannot receive the message sent in step 3.

Cause Analysis
The message is saved in the persistent store successfully. However, when the message is marshalled by the class MessageMarshaller, the field regionDestination is not marshalled and saved to persistent store. When the message is recovered from persistent store after restart, the regionDestination filed of Message is empty so it is unknown which topic this message belongs to.

Possible Cause
In the method org.apache.activemq.broker.region.Topic.activate(ConnectionContext context, final DurableTopicSubscription subscription), the subscription.isRecoveryRequired() check is always false. The message cannot go to the subscription.