diff options
Diffstat (limited to 'qpid/cpp/src/qpid/ha/QueueGuard.cpp')
| -rw-r--r-- | qpid/cpp/src/qpid/ha/QueueGuard.cpp | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/qpid/cpp/src/qpid/ha/QueueGuard.cpp b/qpid/cpp/src/qpid/ha/QueueGuard.cpp index 2108bc4077..d2792e5e17 100644 --- a/qpid/cpp/src/qpid/ha/QueueGuard.cpp +++ b/qpid/cpp/src/qpid/ha/QueueGuard.cpp @@ -70,9 +70,9 @@ QueueGuard::~QueueGuard() { cancel(); } void QueueGuard::enqueued(const Message& m) { // Delay completion ReplicationId id = m.getReplicationId(); - QPID_LOG(trace, logPrefix << "Delayed completion of " << LogMessageId(queue, m)); Mutex::ScopedLock l(lock); if (cancelled) return; // Don't record enqueues after we are cancelled. + QPID_LOG(trace, logPrefix << "Delayed completion of " << LogMessageId(queue, m)); delayed[id] = m.getIngressCompletion(); m.getIngressCompletion()->startCompleter(); } @@ -89,6 +89,7 @@ void QueueGuard::cancel() { queue.removeObserver(observer); Mutex::ScopedLock l(lock); if (cancelled) return; + QPID_LOG(debug, logPrefix << "Cancelled"); cancelled = true; while (!delayed.empty()) complete(delayed.begin(), l); } @@ -111,7 +112,7 @@ bool QueueGuard::complete(ReplicationId id, Mutex::ScopedLock& l) { } void QueueGuard::complete(Delayed::iterator i, Mutex::ScopedLock&) { - QPID_LOG(trace, logPrefix << "Completed " << i->first); + QPID_LOG(trace, logPrefix << "Completed " << queue.getName() << " =" << i->first); i->second->finishCompleter(); delayed.erase(i); } |