summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorKenneth Anthony Giusti <kgiusti@apache.org>2012-03-19 22:15:49 +0000
committerKenneth Anthony Giusti <kgiusti@apache.org>2012-03-19 22:15:49 +0000
commitde47fd1d08f94e7a8f6ba1dab03f6e3d9f4a004b (patch)
treea8ac14989a4e3361787d2e353cc00db26c625f16
parentb4294229869c5f7b0fd5da3c5fe9e6b6b6fd6c6c (diff)
downloadqpid-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.h12
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);