diff options
Diffstat (limited to 'cpp/src/qpid/ha/QueueGuard.cpp')
| -rw-r--r-- | cpp/src/qpid/ha/QueueGuard.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/cpp/src/qpid/ha/QueueGuard.cpp b/cpp/src/qpid/ha/QueueGuard.cpp index b0ef167176..8852554d31 100644 --- a/cpp/src/qpid/ha/QueueGuard.cpp +++ b/cpp/src/qpid/ha/QueueGuard.cpp @@ -61,7 +61,10 @@ QueueGuard::QueueGuard(broker::Queue& q, const BrokerInfo& info) range = QueueRange(q); } -QueueGuard::~QueueGuard() { cancel(); } +QueueGuard::~QueueGuard() { + QPID_LOG(debug, logPrefix << "Cancelled"); + cancel(); +} // NOTE: Called with message lock held. void QueueGuard::enqueued(const Message& m) { @@ -97,7 +100,6 @@ void QueueGuard::completeRange(Delayed::iterator begin, Delayed::iterator end) { } void QueueGuard::cancel() { - QPID_LOG(debug, logPrefix << "Cancelled"); queue.removeObserver(observer); Delayed removed; { |