summaryrefslogtreecommitdiff
path: root/java/broker
diff options
context:
space:
mode:
authorRobert Gemmell <robbie@apache.org>2009-08-10 15:01:01 +0000
committerRobert Gemmell <robbie@apache.org>2009-08-10 15:01:01 +0000
commit5518c23f9a69f6d616abc770bda0677b2f0b51ac (patch)
treec68db3e896175865627810b0df60795443d77101 /java/broker
parentf292bd4d74162a7017cf5cec3b6d624da34c7a1f (diff)
downloadqpid-python-5518c23f9a69f6d616abc770bda0677b2f0b51ac.tar.gz
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/qpid@802819 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker')
-rw-r--r--java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java7
1 files changed, 5 insertions, 2 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
index e450a2060e..d340c9a91f 100644
--- a/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
+++ b/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
@@ -307,13 +307,16 @@ public class AMQQueueMBean extends AMQManagedObject implements ManagedQueue, Que
}
/**
+ * Clears the queue of non-acquired messages
+ *
+ * @return the number of messages deleted
* @see AMQQueue#clearQueue
*/
- public void clearQueue() throws JMException
+ public Long clearQueue() throws JMException
{
try
{
- _queue.clearQueue(_storeContext);
+ return _queue.clearQueue(_storeContext);
}
catch (AMQException ex)
{