diff options
author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2012-03-19 22:15:49 +0000 |
---|---|---|
committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2012-03-19 22:15:49 +0000 |
commit | de47fd1d08f94e7a8f6ba1dab03f6e3d9f4a004b (patch) | |
tree | a8ac14989a4e3361787d2e353cc00db26c625f16 | |
parent | b4294229869c5f7b0fd5da3c5fe9e6b6b6fd6c6c (diff) | |
download | qpid-python-de47fd1d08f94e7a8f6ba1dab03f6e3d9f4a004b.tar.gz |
QPID-3890: revert header updates
git-svn-id: https://svn.apache.org/repos/asf/qpid/branches/qpid-3890@1302689 13f79535-47bb-0310-9956-ffa450edef68
-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 4e24740730..dc0c043c45 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 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&); + void observeEnqueue(const QueuedMessage& msg, const sys::Mutex::ScopedLock& lock); + void observeAcquire(const QueuedMessage& msg, const sys::Mutex::ScopedLock& lock); + void observeRequeue(const QueuedMessage& msg, const sys::Mutex::ScopedLock& lock); + void observeDequeue(const QueuedMessage& msg, const sys::Mutex::ScopedLock& lock); + void observeConsumerAdd( const Consumer&, const sys::Mutex::ScopedLock& lock); + void observeConsumerRemove( const Consumer&, const sys::Mutex::ScopedLock& lock); bool popAndDequeue(QueuedMessage&); bool acquire(const qpid::framing::SequenceNumber& position, QueuedMessage& msg); |