diff options
| author | Alex Rudyy <orudyy@apache.org> | 2013-06-05 13:48:44 +0000 |
|---|---|---|
| committer | Alex Rudyy <orudyy@apache.org> | 2013-06-05 13:48:44 +0000 |
| commit | e3043abef1e7edc2786b6b83a5ae90af98f070d5 (patch) | |
| tree | 5886479c374d8de7ee3560299bd08ba9676708c7 /qpid/java/broker-plugins | |
| parent | 8001b8b2fdbd7cb5fc3abfee53abaf5d31a2ae91 (diff) | |
| download | qpid-python-e3043abef1e7edc2786b6b83a5ae90af98f070d5.tar.gz | |
QPID-4908: Expose queue attributes MessageGroupKey and MessageGroupSharedGroups via queue MBean
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1489872 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/broker-plugins')
2 files changed, 25 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 94fac218ff..cda32cc3f8 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 @@ -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/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 f2663bca4e..3711a90f3b 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 @@ -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()); + } } |