Author: robbie Date: Mon Jul 13 10:25:13 2009 New Revision: 793535 URL: http://svn.apache.org/viewvc?rev=793535&view=rev Log: QPID-1941: ensure old queue entry is deleted as well as dequeued, so it is not later gathered by the viewMessages() method which checks for non-deletion
Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java Modified: qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java URL: http://svn.apache.org/viewvc/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java?rev=793535&r1=793534&r2=793535&view=diff ============================================================================== --- qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java (original) +++ qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java Mon Jul 13 10:25:13 2009 @@ -885,7 +885,7 @@ for (QueueEntry entry : entries) { toQueue.enqueue(storeContext, entry.getMessage()); - + entry.delete(); } } catch (MessageCleanupException e) --------------------------------------------------------------------- Apache Qpid - AMQP Messaging Implementation Project: http://qpid.apache.org Use/Interact: mailto:commits-subscr...@qpid.apache.org