From 3fc22899cf5a4c5a26daef65d720c3bb1de3884d Mon Sep 17 00:00:00 2001 From: "Carl C. Trieloff" Date: Fri, 17 Aug 2007 14:51:24 +0000 Subject: - corrected getMessageCount() for async messages - added test for async message count. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@567059 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/BrokerQueue.cpp | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) (limited to 'cpp/src/qpid') diff --git a/cpp/src/qpid/broker/BrokerQueue.cpp b/cpp/src/qpid/broker/BrokerQueue.cpp index 3ae2ce8de3..ea092bb33b 100644 --- a/cpp/src/qpid/broker/BrokerQueue.cpp +++ b/cpp/src/qpid/broker/BrokerQueue.cpp @@ -223,9 +223,16 @@ void Queue::push(Message::shared_ptr& msg){ } } +/** function only provided for unit tests, or code not in critical message path */ uint32_t Queue::getMessageCount() const{ Mutex::ScopedLock locker(messageLock); - return messages.size(); + + uint32_t count =0; + for ( Messages::const_iterator i = messages.begin(); i != messages.end(); ++i ) { + if ( (*i)->isEnqueueComplete() ) count ++; + } + + return count; } uint32_t Queue::getConsumerCount() const{ -- cgit v1.2.1