summaryrefslogtreecommitdiff
path: root/qpid/cpp/src
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src')
-rw-r--r--qpid/cpp/src/qpid/broker/Queue.cpp11
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)