summaryrefslogtreecommitdiff
path: root/cpp/lib/broker/BrokerQueue.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/lib/broker/BrokerQueue.cpp')
-rw-r--r--cpp/lib/broker/BrokerQueue.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/cpp/lib/broker/BrokerQueue.cpp b/cpp/lib/broker/BrokerQueue.cpp
index 789e652947..31309bd6c5 100644
--- a/cpp/lib/broker/BrokerQueue.cpp
+++ b/cpp/lib/broker/BrokerQueue.cpp
@@ -32,7 +32,7 @@ using namespace qpid::sys;
using namespace qpid::framing;
using boost::format;
-Queue::Queue(const string& _name, u_int32_t _autodelete,
+Queue::Queue(const string& _name, uint32_t _autodelete,
MessageStore* const _store,
const ConnectionToken* const _owner) :
@@ -166,7 +166,7 @@ Message::shared_ptr Queue::dequeue(){
return msg;
}
-u_int32_t Queue::purge(){
+uint32_t Queue::purge(){
Mutex::ScopedLock locker(lock);
int count = messages.size();
while(!messages.empty()) pop();
@@ -189,12 +189,12 @@ void Queue::push(Message::shared_ptr& msg){
}
}
-u_int32_t Queue::getMessageCount() const{
+uint32_t Queue::getMessageCount() const{
Mutex::ScopedLock locker(lock);
return messages.size();
}
-u_int32_t Queue::getConsumerCount() const{
+uint32_t Queue::getConsumerCount() const{
Mutex::ScopedLock locker(lock);
return consumers.size();
}