Author: robbie
Date: Thu Jul 9 14:46:57 2009
New Revision: 792565
URL: http://svn.apache.org/viewvc?rev=792565&view=rev
Log:
QPID-1941: ensure old queue entry is deleted as well as dequeued, so it is not
gathered by the viewMessages() method which checks for non deletion
Modified:
qpid/branches/jmx_mc_gsoc09/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
Modified:
qpid/branches/jmx_mc_gsoc09/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
URL:
http://svn.apache.org/viewvc/qpid/branches/jmx_mc_gsoc09/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java?rev=792565&r1=792564&r2=792565&view=diff
==============================================================================
---
qpid/branches/jmx_mc_gsoc09/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
(original)
+++
qpid/branches/jmx_mc_gsoc09/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/SimpleAMQQueue.java
Thu Jul 9 14:46:57 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:[email protected]
