commit 1afd5b0a397130ed0766feb91f612746f98fd53c
author Alex Rudyy <orudyy@apache.org> Mon Feb 22 10:44:28 2016 +0000
committer Alex Rudyy <orudyy@apache.org> Mon Feb 22 10:44:28 2016 +0000
tree 9114b67802897975e1e6298a45be2af5bba1e889
parent 570d1f34ffe9bad1dbdd4f58208c52eebb36844a
parent 8eb5c5b2b12ebc9a6cf5a292d4d578785a57a6bd

[maven-release-plugin] copy for tag 6.0.1

broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java

diff --git a/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java b/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java
index e64a6dc..b63bb10 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/consumer/AbstractConsumerTarget.java
@@ -250,6 +250,11 @@
             ConsumerMessageInstancePair instance;
             while((instance = _queue.poll()) != null)
             {
+                MessageInstance entry = instance.getEntry();
+                if(entry.isAcquiredBy(instance.getConsumer()))
+                {
+                    entry.release();
+                }
                 instance.release();
             }
             doCloseInternal();