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 | 5715d967f11f5ce684914d8b133683912e2af7bb (patch) | |
| tree | edf57575498cfacdaf45d016f2f4f0149944276e | |
| parent | db7b30e0f7e7e080071df08c6589036820bdb443 (diff) | |
| download | qpid-python-5715d967f11f5ce684914d8b133683912e2af7bb.tar.gz | |
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
| -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 } } |