From 9d4cbbe253442fc625a4d2bf61314df7fa26e842 Mon Sep 17 00:00:00 2001 From: Robert Gemmell Date: Mon, 10 Aug 2009 15:01:01 +0000 Subject: QPID-2018: Updated AMQQueueMBean to make use of the AMQQueue clearQueue return value to report the number of messages deleted. Updated management console accordingly, also indicating that it is only non-acquired messaes that are cleared git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@802819 13f79535-47bb-0310-9956-ffa450edef68 --- .../ui/views/queue/QueueOperationsTabControl.java | 17 +++++++++++++++-- 1 file changed, 15 insertions(+), 2 deletions(-) (limited to 'qpid/java/management/eclipse-plugin') diff --git a/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java b/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java index c838a3e414..c7c7a1791a 100644 --- a/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java +++ b/qpid/java/management/eclipse-plugin/src/main/java/org/apache/qpid/management/ui/views/queue/QueueOperationsTabControl.java @@ -457,8 +457,21 @@ public class QueueOperationsTabControl extends TabControl { try { - _qmb.clearQueue(); - ViewUtility.operationResultFeedback(null, "Queue cleared", null); + if(_ApiVersion.greaterThanOrEqualTo(1, 3)) + { + //Qpid JMX API 1.3+, returns the number of messages deleted + Long numDeleted = _qmb.clearQueue(); + String message = "Queue cleared of " + numDeleted + + " non-acquired message" + (numDeleted == 1 ? "": "s"); + + ViewUtility.operationResultFeedback(null, message, null); + } + else + { + //Qpid JMX API 1.2 or below, void return + _qmb.clearQueue(); + ViewUtility.operationResultFeedback(null, "Queue cleared of non-acquired messages", null); + } } catch (Exception e2) { -- cgit v1.2.1