Fix for messages that stick around in unsubscribed queues after rollback

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/qpid.0-9@508150 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 6 insertions, 0 deletions

diff --git a/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java b/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
index d750ee7f72..73485d2c20 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/txn/LocalTransactionalContext.java
@@ -69,6 +69,11 @@ public class LocalTransactionalContext implements TransactionalContext
             this.message = message;
             this.queue = queue;
         }
+        
+        public String toString()
+        {
+            return "msg=" + message.getBody() + "; q=" + queue.getName();
+        }
     }
 
     public LocalTransactionalContext(MessageStore messageStore, StoreContext storeContext,
@@ -89,6 +94,7 @@ public class LocalTransactionalContext implements TransactionalContext
     public void rollback() throws AMQException
     {
         _txnBuffer.rollback(_storeContext);
+        _postCommitDeliveryList.clear();
     }
 
     public void deliver(AMQMessage message, AMQQueue queue) throws AMQException