From 81de16dca5f5b035a25ad87e9e3fbb4c45093e2f Mon Sep 17 00:00:00 2001 From: Alex Rudyy Date: Wed, 5 Jun 2013 13:48:44 +0000 Subject: QPID-4908: Expose queue attributes MessageGroupKey and MessageGroupSharedGroups via queue MBean git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1489872 13f79535-47bb-0310-9956-ffa450edef68 --- .../java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java | 13 +++++++++++++ .../org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java | 12 ++++++++++++ 2 files changed, 25 insertions(+) (limited to 'java/broker-plugins') diff --git a/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java b/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java index 94fac218ff..cda32cc3f8 100644 --- a/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java +++ b/java/broker-plugins/management-jmx/src/main/java/org/apache/qpid/server/jmx/mbeans/QueueMBean.java @@ -662,4 +662,17 @@ public class QueueMBean extends AMQManagedObject implements ManagedQueue, QueueN final Number statistic = (Number) _queue.getStatistics().getStatistic(name); return statistic == null ? Integer.valueOf(0) : statistic; } + + @Override + public String getMessageGroupKey() + { + return (String) _queue.getAttribute(Queue.MESSAGE_GROUP_KEY); + } + + @Override + public boolean isMessageGroupSharedGroups() + { + Boolean value = (Boolean) _queue.getAttribute(Queue.MESSAGE_GROUP_SHARED_GROUPS); + return value == null ? false : value.booleanValue(); + } } diff --git a/java/broker-plugins/management-jmx/src/test/java/org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java b/java/broker-plugins/management-jmx/src/test/java/org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java index f2663bca4e..3711a90f3b 100644 --- a/java/broker-plugins/management-jmx/src/test/java/org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java +++ b/java/broker-plugins/management-jmx/src/test/java/org/apache/qpid/server/jmx/mbeans/QueueMBeanTest.java @@ -436,4 +436,16 @@ public class QueueMBeanTest extends QpidTestCase byte[] data = (byte[]) comp.get(ManagedQueue.CONTENT); assertEquals(messageSize, data.length); } + + public void testGetMessageGroupKey() + { + when(_mockQueue.getAttribute(Queue.MESSAGE_GROUP_KEY)).thenReturn(getTestName()); + assertEquals("Unexpected message group key", getTestName(), _queueMBean.getMessageGroupKey()); + } + + public void testIsSharedMessageGroup() + { + when(_mockQueue.getAttribute(Queue.MESSAGE_GROUP_SHARED_GROUPS)).thenReturn(true); + assertEquals("Unexpected message group sharing", true, _queueMBean.isMessageGroupSharedGroups()); + } } -- cgit v1.2.1