diff options
Diffstat (limited to 'qpid/cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
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 } } |