diff options
| author | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2007-03-13 16:04:00 +0000 |
|---|---|---|
| committer | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2007-03-13 16:04:00 +0000 |
| commit | d7ffa02047b5bfeea5c0289976d5355b69a5a11c (patch) | |
| tree | aebed39d0c6fa6b63b18658e4323e55b3099bb78 /java/broker/src/main | |
| parent | d697dcb5a267ab1cb363d3a6e675a5f6f505b838 (diff) | |
| download | qpid-python-d7ffa02047b5bfeea5c0289976d5355b69a5a11c.tar.gz | |
QPID-411 : ClearQueue functionality of AMQQueue doesn't reset the queue depth
AMQQueueMBeanTest.java moved to Broker tests
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@517745 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src/main')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java b/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java index 6122d191f8..f9b5b5174c 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java +++ b/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java @@ -378,6 +378,7 @@ public class ConcurrentSelectorDeliveryManager implements DeliveryManager msg = getNextMessage(); count++; } + _totalMessageSize.set(0L); } _lock.unlock(); return count; |