diff options
Diffstat (limited to 'cpp/src/qpid/broker/Queue.h')
-rw-r--r-- | cpp/src/qpid/broker/Queue.h | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/cpp/src/qpid/broker/Queue.h b/cpp/src/qpid/broker/Queue.h index 17ace522c3..7ee9106ef0 100644 --- a/cpp/src/qpid/broker/Queue.h +++ b/cpp/src/qpid/broker/Queue.h @@ -67,7 +67,7 @@ namespace qpid { const string name; const bool autodelete; MessageStore* const store; - const ConnectionToken* const owner; + const ConnectionToken* owner; Consumers acquirers; Consumers browsers; Messages messages; @@ -155,6 +155,8 @@ namespace qpid { uint32_t getConsumerCount() const; inline const string& getName() const { return name; } inline const bool isExclusiveOwner(const ConnectionToken* const o) const { return o == owner; } + inline void releaseExclusiveOwnership() { owner = 0; } + inline void setExclusiveOwner(const ConnectionToken* const o) { owner = o; } inline bool hasExclusiveConsumer() const { return exclusive; } inline bool hasExclusiveOwner() const { return owner != 0; } inline bool isDurable() const { return store != 0; } |