diff options
| author | Pavel Moravec <pmoravec@apache.org> | 2015-04-30 13:29:34 +0000 |
|---|---|---|
| committer | Pavel Moravec <pmoravec@apache.org> | 2015-04-30 13:29:34 +0000 |
| commit | a8c38e0a0c3bbaa3e83c1ae1ebf4b41620a06797 (patch) | |
| tree | 9bfee491065a002e75fc99728c2feb5d2c6e8f84 | |
| parent | 554319f567131d3353e4f19db7b5e57cd8cad166 (diff) | |
| download | qpid-python-a8c38e0a0c3bbaa3e83c1ae1ebf4b41620a06797.tar.gz | |
QPID-6524: [C++ broker]: Fix for QPID-5107 incomplete for queues
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1676982 13f79535-47bb-0310-9956-ffa450edef68
| -rw-r--r-- | cpp/src/qpid/broker/Queue.cpp | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Queue.cpp b/cpp/src/qpid/broker/Queue.cpp index 4dd6455104..97b5a75e28 100644 --- a/cpp/src/qpid/broker/Queue.cpp +++ b/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 } } |