diff options
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp index 1116941c4f..111c47a861 100644 --- a/qpid/cpp/src/qpid/broker/Queue.cpp +++ b/qpid/cpp/src/qpid/broker/Queue.cpp @@ -1033,7 +1033,9 @@ bool Queue::dequeue(TransactionContext* ctxt, const QueuedMessage& msg) } } - mgntDeqStats(msg.payload, mgmtObject, brokerMgmtObject); + if (!ctxt) { + mgntDeqStats(msg.payload, mgmtObject, brokerMgmtObject); + } // This check prevents messages which have been forced persistent on one queue from dequeuing // from another on which no forcing has taken place and thus causing a store error. |