diff options
| author | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2006-10-25 11:14:27 +0000 |
|---|---|---|
| committer | Bhupendra Bhusman Bhardwaj <bhupendrab@apache.org> | 2006-10-25 11:14:27 +0000 |
| commit | b1f9d150e273a9dd82cb185f6fec4260c5bf0342 (patch) | |
| tree | f77ac10e9fe18ceb785bb2f7426d942c3916aefa /qpid/java | |
| parent | 908cc6ea00b13711da4c534facff572b16960187 (diff) | |
| download | qpid-python-b1f9d150e273a9dd82cb185f6fec4260c5bf0342.tar.gz | |
MBean updated and corrected a code merging mistake.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@467605 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
| -rw-r--r-- | qpid/java/broker/src/org/apache/qpid/server/queue/AMQQueue.java | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/qpid/java/broker/src/org/apache/qpid/server/queue/AMQQueue.java b/qpid/java/broker/src/org/apache/qpid/server/queue/AMQQueue.java index 189a8289ea..17511fb7e7 100644 --- a/qpid/java/broker/src/org/apache/qpid/server/queue/AMQQueue.java +++ b/qpid/java/broker/src/org/apache/qpid/server/queue/AMQQueue.java @@ -144,7 +144,7 @@ public class AMQQueue implements Managable private TabularType _messagelistDataType = null; private String[] _contentNames = {"SerialNumber", "ContentBody"}; - private String[] _contentDesc = {"SerialNumber", "Message Content"}; + private String[] _contentDesc = {"Serial Number", "Content Body"}; private String[] _contentIndex = {"SerialNumber"}; private OpenType[] _contentType = new OpenType[2]; private CompositeType _contentBodyType = null; @@ -165,12 +165,12 @@ public class AMQQueue implements Managable _contentType[0] = SimpleType.INTEGER; _contentType[1] = new ArrayType(1, SimpleType.BYTE); _contentBodyType = new CompositeType("Content", - "Message body content", + "Content", _contentNames, _contentDesc, _contentType); _contentBodyListType = new TabularType("MessageContents", - "MessageContent", + "Message Contents", _contentBodyType, _contentIndex); @@ -699,7 +699,6 @@ public class AMQQueue implements Managable private void process(AMQMessage msg) throws FailedDequeueException { _deliveryMgr.deliver(getName(), msg); - updateReceivedMessageCount(msg); try { msg.checkDeliveredToConsumer(); |