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 | 62fe39516a1bb45d206ad68aa7e1ec60966367a9 (patch) | |
| tree | d12dc1f50a3647ef1845d44116a10539175c5ef9 /qpid/java/broker-plugins | |
| parent | cdc1d5ce0b40acfea625c8c43e41372bac3a0f8a (diff) | |
| download | qpid-python-62fe39516a1bb45d206ad68aa7e1ec60966367a9.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@1424757 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins')
| -rw-r--r-- | qpid/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/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java b/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java index 5c8b0f7194..94fac218ff 100644 --- a/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java +++ b/qpid/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; } }); } |
