[AMQ-4472] consumer.close() on transacted session does not release prefetched messages

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 5.8.0
• Fix Version/s: 5.9.0
• Component/s: JMS client
• Labels: transactions
• Assignee: Hiram R. Chirino
• Reporter: Jason Sherman
• Created: 16/Apr/13 17:50
• Updated: 16/Jul/14 20:30
• Resolved: 26/Apr/13 15:43

Description

When using transactions an issue can arise where the consumer has messages in it's prefetch and when consumer.close() is called the consumer is not closed and does not release the messages.

The use case is as follows:

1) Create producer
2) Create consumer
3) Send message to queue
4) Commit session
5) Send a new message
6) Close the consumer
7) Start a new consumer
8) Try to receive the message

Test case will be attached shortly.

Issue Links

• is related to: AMQNET-484 A consumer in a Transacted Session with no pending Acks can be eagerly closed.