diff options
| author | Robert Gemmell <robbie@apache.org> | 2012-12-20 23:29:28 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2012-12-20 23:29:28 +0000 |
| commit | 2d1044ec5d45230786e280af3ad69d56aac04583 (patch) | |
| tree | 5d76ce89bebf5e812edc0859753d71762074d9a6 /java/broker-plugins | |
| parent | 3fc13a8214400aa0da17520b93996d04a59a09df (diff) | |
| download | qpid-python-2d1044ec5d45230786e280af3ad69d56aac04583.tar.gz | |
QPID-4512: stop the delete visitor indicating completion upon the first matching queue entry, or any for that matter: it needs to check them all.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1424757 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker-plugins')
| -rw-r--r-- | java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java b/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java index 5c8b0f7194..94fac218ff 100644 --- a/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java +++ b/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java @@ -513,7 +513,6 @@ public class QueueMBean extends AMQManagedObject implements ManagedQueue, QueueN { _queue.visit(new QueueEntryVisitor() { - public boolean visit(final QueueEntry entry) { final ServerMessage message = entry.getMessage(); @@ -525,11 +524,9 @@ public class QueueMBean extends AMQManagedObject implements ManagedQueue, QueueN && (messageId <= toMessageId)) { txn.dequeue(entry); - return true; } - return false; } - return true; + return false; } }); } |
