diff options
Diffstat (limited to 'qpid/cpp/src/qpid/broker/Queue.h')
| -rw-r--r-- | qpid/cpp/src/qpid/broker/Queue.h | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/qpid/cpp/src/qpid/broker/Queue.h b/qpid/cpp/src/qpid/broker/Queue.h index 9cdfb9846e..4e24740730 100644 --- a/qpid/cpp/src/qpid/broker/Queue.h +++ b/qpid/cpp/src/qpid/broker/Queue.h @@ -144,12 +144,12 @@ class Queue : public boost::enable_shared_from_this<Queue>, /** update queue observers, stats, policy, etc when the messages' state changes. * messageLock is held by caller */ - void observeEnqueueLH(const QueuedMessage& msg); - void observeAcquireLH(const QueuedMessage& msg); - void observeRequeueLH(const QueuedMessage& msg); - void observeDequeueLH(const QueuedMessage& msg); - void observeConsumerAddLH( const Consumer& ); - void observeConsumerRemoveLH( const Consumer& ); + void observeEnqueue(const QueuedMessage& msg, const qpid::sys::Mutex::ScopedLock&); + void observeAcquire(const QueuedMessage& msg, const qpid::sys::Mutex::ScopedLock&); + void observeRequeue(const QueuedMessage& msg, const qpid::sys::Mutex::ScopedLock&); + void observeDequeue(const QueuedMessage& msg, const qpid::sys::Mutex::ScopedLock&); + void observeConsumerAdd( const Consumer&, const qpid::sys::Mutex::ScopedLock&); + void observeConsumerRemove( const Consumer&, const qpid::sys::Mutex::ScopedLock&); bool popAndDequeue(QueuedMessage&); bool acquire(const qpid::framing::SequenceNumber& position, QueuedMessage& msg); |