Author: rgodfrey
Date: Mon Feb 22 09:59:03 2016
New Revision: 1731612
URL: http://svn.apache.org/viewvc?rev=1731612&view=rev
Log:
QPID-6817 : Ensure queue entires are released when connection is abrubtly closed
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java?rev=1731612&r1=1731611&r2=1731612&view=diff
==============================================================================
---
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java
(original)
+++
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java
Mon Feb 22 09:59:03 2016
@@ -250,6 +250,11 @@ public abstract class AbstractConsumerTa
ConsumerMessageInstancePair instance;
while((instance = _queue.poll()) != null)
{
+ MessageInstance entry = instance.getEntry();
+ if(entry.isAcquiredBy(instance.getConsumer()))
+ {
+ entry.release();
+ }
instance.release();
}
doCloseInternal();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
