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();