diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-08-07 13:14:06 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-08-07 13:14:06 +0000 |
| commit | 400ffb496c30a2a6554af7cf7739db40b497e5c2 (patch) | |
| tree | 153a0795d2cc0f0d32b3dcb630d5f82e1f233b6f /qpid/java/broker-plugins/management-jmx | |
| parent | 87456620af31532eb5af81c0207e7533ae67fb39 (diff) | |
| download | qpid-python-400ffb496c30a2a6554af7cf7739db40b497e5c2.tar.gz | |
QPID-5970 : [Java Broker] Expose "age of oldest message on queue" to management apis
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1616487 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins/management-jmx')
2 files changed, 12 insertions, 0 deletions
diff --git a/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java b/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java index a1fec6f69e..ca092fe6f8 100644 --- a/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java +++ b/qpid/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java @@ -700,4 +700,10 @@ public class QueueMBean extends AMQManagedObject implements ManagedQueue, QueueN { return _queue.isMessageGroupSharedGroups(); } + + @Override + public Long getOldestMessageAge() + { + return _queue.getOldestMessageAge(); + } } diff --git a/qpid/java/broker-plugins/management-jmx/src/test/java/org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java b/qpid/java/broker-plugins/management-jmx/src/test/java/org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java index 6f31dc6d04..671920c33d 100644 --- a/qpid/java/broker-plugins/management-jmx/src/test/java/org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java +++ b/qpid/java/broker-plugins/management-jmx/src/test/java/org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java @@ -118,6 +118,12 @@ public class QueueMBeanTest extends QpidTestCase assertStatistic("consumerCount", 3); } + public void testOldestMessageAge() throws Exception + { + when(_mockQueue.getOldestMessageAge()).thenReturn(3l); + assertStatistic("oldestMessageAge", 3l); + } + /********** Simple Attributes **********/ public void testGetQueueDescription() throws Exception |