diff options
| author | Robert Gemmell <robbie@apache.org> | 2009-07-13 10:23:22 +0000 |
|---|---|---|
| committer | Robert Gemmell <robbie@apache.org> | 2009-07-13 10:23:22 +0000 |
| commit | 82e9550aa4018670f5fc901bd838af2115a3fcff (patch) | |
| tree | 3c05bee43ef47c6a23945479ca028d94b080fc9d /java/broker/src | |
| parent | fb4502a531c6a6480dd7b9c9481c375f58b91b8e (diff) | |
| download | qpid-python-82e9550aa4018670f5fc901bd838af2115a3fcff.tar.gz | |
QPID-1944: expose Connection tabular/composite data key values through management interface
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@793533 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/broker/src')
| -rw-r--r-- | java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java | 10 |
1 files changed, 4 insertions, 6 deletions
diff --git a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java index 9f7c74ba5e..65235ba9b9 100644 --- a/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java +++ b/java/broker/src/main/java/org/apache/qpid/server/protocol/AMQProtocolSessionMBean.java @@ -79,9 +79,7 @@ public class AMQProtocolSessionMBean extends AMQManagedObject implements Managed private String _name = null; // openmbean data types for representing the channel attributes - private static final String[] _channelAtttibuteNames = - { "Channel Id", "Transactional", "Default Queue", "Unacknowledged Message Count" }; - private static final String[] _indexNames = { _channelAtttibuteNames[0] }; + private static final OpenType[] _channelAttributeTypes = { SimpleType.INTEGER, SimpleType.BOOLEAN, SimpleType.STRING, SimpleType.INTEGER }; private static CompositeType _channelType = null; // represents the data type for channel data @@ -119,9 +117,9 @@ public class AMQProtocolSessionMBean extends AMQManagedObject implements Managed private static void init() throws OpenDataException { _channelType = - new CompositeType("Channel", "Channel Details", _channelAtttibuteNames, _channelAtttibuteNames, + new CompositeType("Channel", "Channel Details", COMPOSITE_ITEM_NAMES, COMPOSITE_ITEM_DESCRIPTIONS, _channelAttributeTypes); - _channelsType = new TabularType("Channels", "Channels", _channelType, _indexNames); + _channelsType = new TabularType("Channels", "Channels", _channelType, TABULAR_UNIQUE_INDEX); } public String getClientId() @@ -247,7 +245,7 @@ public class AMQProtocolSessionMBean extends AMQManagedObject implements Managed channel.getUnacknowledgedMessageMap().size() }; - CompositeData channelData = new CompositeDataSupport(_channelType, _channelAtttibuteNames, itemValues); + CompositeData channelData = new CompositeDataSupport(_channelType, COMPOSITE_ITEM_NAMES, itemValues); channelsList.put(channelData); } |
