You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by bh...@apache.org on 2007/02/27 13:26:29 UTC
svn commit: r512229 -
/incubator/qpid/branches/perftesting/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
Author: bhupendrab
Date: Tue Feb 27 04:26:28 2007
New Revision: 512229
URL: http://svn.apache.org/viewvc?view=rev&rev=512229
Log:
QPID-390 (queue depth issue resolved) The commented code is updated
Modified:
incubator/qpid/branches/perftesting/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
Modified: incubator/qpid/branches/perftesting/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java
URL: http://svn.apache.org/viewvc/incubator/qpid/branches/perftesting/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java?view=diff&rev=512229&r1=512228&r2=512229
==============================================================================
--- incubator/qpid/branches/perftesting/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java (original)
+++ incubator/qpid/branches/perftesting/qpid/java/broker/src/main/java/org/apache/qpid/server/queue/AMQQueueMBean.java Tue Feb 27 04:26:28 2007
@@ -188,22 +188,8 @@
/** 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 */