diff options
| author | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2007-02-27 12:26:28 +0000 |
|---|---|---|
| committer | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2007-02-27 12:26:28 +0000 |
| commit | 97d015f74813f95d71d6a0d8548555178b290df7 (patch) | |
| tree | e6bdfa2b72ef22c24950338752d014d07531ce54 | |
| parent | a6f06a587caf9ae9a08b0c01f89ecce9bb0652d3 (diff) | |
| download | qpid-python-97d015f74813f95d71d6a0d8548555178b290df7.tar.gz | |
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
| -rw-r--r-- | qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java | 18 |
1 files changed, 2 insertions, 16 deletions
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<AMQMessage> 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 */ |