diff options
| -rw-r--r-- | cpp/src/qpid/broker/Connection.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/cpp/src/qpid/broker/Connection.cpp b/cpp/src/qpid/broker/Connection.cpp index 680d0c7adf..82761ac7e4 100644 --- a/cpp/src/qpid/broker/Connection.cpp +++ b/cpp/src/qpid/broker/Connection.cpp @@ -184,7 +184,8 @@ bool isMessage(const AMQMethodBody* method) void Connection::recordFromServer(const framing::AMQFrame& frame) { - if (mgmtObject != 0) + // Don't record management stats in cluster-unsafe contexts + if (mgmtObject != 0 && isClusterSafe()) { mgmtObject->inc_framesToClient(); mgmtObject->inc_bytesToClient(frame.encodedSize()); @@ -196,7 +197,8 @@ void Connection::recordFromServer(const framing::AMQFrame& frame) void Connection::recordFromClient(const framing::AMQFrame& frame) { - if (mgmtObject != 0) + // Don't record management stats in cluster-unsafe contexts + if (mgmtObject != 0 && isClusterSafe()) { mgmtObject->inc_framesFromClient(); mgmtObject->inc_bytesFromClient(frame.encodedSize()); |