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 | 4d692b9645b2d2c0842dd4d85e23d1d26e8dc34e (patch) | |
| tree | 670aae11dbb9d4aa650104a0ffe2136dc384b050 /qpid/java/broker/src/main | |
| parent | 1cb785d8ebfb6b810e0b633e72efadbba252e6bd (diff) | |
| download | qpid-python-4d692b9645b2d2c0842dd4d85e23d1d26e8dc34e.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@517745 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker/src/main')
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java index 6122d191f8..f9b5b5174c 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/ConcurrentSelectorDeliveryManager.java +++ b/qpid/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; |