diff options
| -rw-r--r-- | java/management/tools/qpid-cli/src/org/apache/qpid/commands/objects/QueueObject.java | 33 |
1 files changed, 6 insertions, 27 deletions
diff --git a/java/management/tools/qpid-cli/src/org/apache/qpid/commands/objects/QueueObject.java b/java/management/tools/qpid-cli/src/org/apache/qpid/commands/objects/QueueObject.java index 7c82682c27..fcf0464ced 100644 --- a/java/management/tools/qpid-cli/src/org/apache/qpid/commands/objects/QueueObject.java +++ b/java/management/tools/qpid-cli/src/org/apache/qpid/commands/objects/QueueObject.java @@ -22,10 +22,10 @@ package org.apache.qpid.commands.objects; import javax.management.MBeanServerConnection; -import javax.management.MBeanAttributeInfo; -import javax.management.MBeanInfo; import javax.management.ObjectName; +import org.apache.qpid.management.common.mbeans.ManagedQueue; + public class QueueObject extends ObjectNames { public QueueObject(MBeanServerConnection mbsc) @@ -47,33 +47,12 @@ public class QueueObject extends ObjectNames public int getmessagecount(ObjectName queue) { - int attr_count = 0; - String value; - Integer depth = null; - + Number depth = null; + try { - MBeanInfo bean_info; - bean_info = mbsc.getMBeanInfo(queue); - MBeanAttributeInfo[] attr_info = bean_info.getAttributes(); - if (attr_info == null) - return 0; - else - { - for (MBeanAttributeInfo attr : attr_info) - { - Object toWrite = null; - attr_count++; - toWrite = mbsc.getAttribute(queue, attr.getName()); - if (attr_count == 7) - { - value = toWrite.toString(); - depth = new Integer(value); - } - } - - } - + depth = (Number) mbsc.getAttribute(queue, ManagedQueue.ATTR_MSG_COUNT); + } catch (Exception ex) { |