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
