From b19d20c0277ff20609f9f0774224accd5ff3e452 Mon Sep 17 00:00:00 2001
From: "Carl C. Trieloff" <cctrieloff@apache.org>
Date: Fri, 26 Oct 2007 02:37:54 +0000
Subject: - added patch from Tedd - QPID-660

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@588478 13f79535-47bb-0310-9956-ffa450edef68
---
 cpp/src/qpid/broker/ManagementObjectQueue.cpp | 26 ++++++++++++++++++++------
 1 file changed, 20 insertions(+), 6 deletions(-)

(limited to 'cpp/src/qpid/broker/ManagementObjectQueue.cpp')

diff --git a/cpp/src/qpid/broker/ManagementObjectQueue.cpp b/cpp/src/qpid/broker/ManagementObjectQueue.cpp
index b81cd7b60d..d30cda03a4 100644
--- a/cpp/src/qpid/broker/ManagementObjectQueue.cpp
+++ b/cpp/src/qpid/broker/ManagementObjectQueue.cpp
@@ -76,7 +76,9 @@ ManagementObjectQueue::~ManagementObjectQueue () {}
 
 void ManagementObjectQueue::writeSchema (Buffer& buf)
 {
-    schemaItem (buf, TYPE_STRING, "name",                "Queue Name", true);
+    schemaNeeded = false;
+
+    schemaItem (buf, TYPE_STRING, "name",                "Queue Name", true, true);
     schemaItem (buf, TYPE_BOOL,   "durable",             "Durable",    true);
     schemaItem (buf, TYPE_BOOL,   "autoDelete",          "AutoDelete", true);
 
@@ -115,21 +117,24 @@ void ManagementObjectQueue::writeSchema (Buffer& buf)
     schemaItem (buf, TYPE_UINT32, "consumersHigh",       "Consumer high water mark this interval");
 
     schemaListEnd (buf);
-
-    schemaNeeded = false;
 }
 
 void ManagementObjectQueue::writeConfig (Buffer& buf)
 {
+    configChanged = false;
+
+    writeTimestamps    (buf);
     buf.putShortString (name);
     buf.putOctet       (durable    ? 1 : 0);
     buf.putOctet       (autoDelete ? 1 : 0);
-    
-    configChanged = false;
 }
 
 void ManagementObjectQueue::writeInstrumentation (Buffer& buf)
 {
+    instChanged = false;
+
+    writeTimestamps (buf);
+    buf.putShortString (name);
     buf.putLongLong (msgTotalEnqueues);
     buf.putLongLong (msgTotalDequeues);
     buf.putLongLong (msgTxEnqueues);
@@ -164,5 +169,14 @@ void ManagementObjectQueue::writeInstrumentation (Buffer& buf)
     buf.putLong     (consumersLow);
     buf.putLong     (consumersHigh);
 
-    instChanged = false;
+    msgDepthLow        = msgDepth;
+    msgDepthHigh       = msgDepth;
+    byteDepthLow       = byteDepth;
+    byteDepthHigh      = byteDepth;
+    enqueueTxCountLow  = enqueueTxCount;
+    enqueueTxCountHigh = enqueueTxCount;
+    dequeueTxCountLow  = dequeueTxCount;
+    dequeueTxCountHigh = dequeueTxCount;
+    consumersLow       = consumers;
+    consumersHigh      = consumers;
 }
-- 
cgit v1.2.1