diff options
Diffstat (limited to 'java/broker-plugins')
2 files changed, 25 insertions, 0 deletions
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()); + } } |