From 5715d967f11f5ce684914d8b133683912e2af7bb Mon Sep 17 00:00:00 2001 From: Pavel Moravec Date: Thu, 30 Apr 2015 13:29:34 +0000 Subject: QPID-6524: [C++ broker]: Fix for QPID-5107 incomplete for queues git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1676982 13f79535-47bb-0310-9956-ffa450edef68 --- qpid/cpp/src/qpid/broker/Queue.cpp | 3 +++ 1 file changed, 3 insertions(+) (limited to 'qpid/cpp') diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp index 4dd6455104..97b5a75e28 100644 --- a/qpid/cpp/src/qpid/broker/Queue.cpp +++ b/qpid/cpp/src/qpid/broker/Queue.cpp @@ -1136,6 +1136,8 @@ void Queue::abandoned(const Message& message) void Queue::destroyed() { + if (mgmtObject != 0) + mgmtObject->debugStats("destroying"); unbind(broker->getExchanges()); remove(0, 0, boost::bind(&Queue::abandoned, this, _1), REPLICATOR/*even acquired message are treated as abandoned*/, false); if (alternateExchange.get()) { @@ -1159,6 +1161,7 @@ void Queue::destroyed() mgmtObject->resourceDestroy(); if (brokerMgmtObject) brokerMgmtObject->dec_queueCount(); + mgmtObject = _qmf::Queue::shared_ptr(); // dont print debugStats in Queue::~Queue } } -- cgit v1.2.1