Author: bhupendrab
Date: Thu Mar 15 03:39:31 2007
New Revision: 518569
URL: http://svn.apache.org/viewvc?view=rev&rev=518569
Log:
QPID-170
Modified:
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java
Modified:
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java?view=diff&rev=518569&r1=518568&r2=518569
==============================================================================
---
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java
(original)
+++
incubator/qpid/trunk/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java
Thu Mar 15 03:39:31 2007
@@ -527,7 +527,7 @@
_lock.lock();
for (AMQMessage msg : movedMessageList)
{
- addMessageToQueue(msg, true);
+ addMessageToQueue(msg, false);
}
// enqueue on the pre delivery queues
