diff options
Diffstat (limited to 'qpid/cpp/src')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.cpp | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.cpp b/qpid/cpp/src/qpid/broker/Queue.cpp index 74d23fdabf..2c8f8c2f0e 100644 --- a/qpid/cpp/src/qpid/broker/Queue.cpp +++ b/qpid/cpp/src/qpid/broker/Queue.cpp @@ -521,16 +521,17 @@ void Queue::markInUse(bool controlling) void Queue::releaseFromUse(bool controlling) { + bool trydelete; if (controlling) { - { - Mutex::ScopedLock locker(messageLock); - users.removeLifecycleController(); - } - scheduleAutoDelete(); + Mutex::ScopedLock locker(messageLock); + users.removeLifecycleController(); + trydelete = true; } else { Mutex::ScopedLock locker(messageLock); users.removeOther(); + trydelete = isUnused(locker); } + if (trydelete) scheduleAutoDelete(); } void Queue::consume(Consumer::shared_ptr c, bool requestExclusive) |
