From 97d015f74813f95d71d6a0d8548555178b290df7 Mon Sep 17 00:00:00 2001 From: Bhupendra Bhusman Bhardwaj Date: Tue, 27 Feb 2007 12:26:28 +0000 Subject: QPID-390 (queue depth issue resolved) The commented code is updated git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/perftesting@512229 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/server/queue/AMQQueueMBean.java | 18 ++---------------- 1 file changed, 2 insertions(+), 16 deletions(-) (limited to 'qpid/java/broker') diff --git a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java index 6211d7f349..ec9aad05a9 100644 --- a/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java +++ b/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java @@ -188,22 +188,8 @@ public class AMQQueueMBean extends AMQManagedObject implements ManagedQueue, Que /** returns the size of messages(KB) in the queue. */ public Long getQueueDepth() { -// List list = _queue.getMessagesOnTheQueue(); -// if (list.size() == 0) -// { -// return 0l; -// } -// -// long queueDepth = 0; -// for (AMQMessage message : list) -// { -// queueDepth = queueDepth + getMessageSize(message); -// } -// return (long) Math.round(queueDepth / 1000); - - //fixme delegate to DeliveryManger - //return _queue.getTotalSize(); - return 0L; + long queueBytesSize = _queue.getQueueDepth(); + return queueBytesSize >> 10 ; } /** returns size of message in bytes */ -- cgit v1.2.1