1 files changed, 7 insertions, 1 deletions
diff --git a/cpp/broker/src/Queue.cpp b/cpp/broker/src/Queue.cpp
index f7b8605b03..1db4454235 100644
--- a/cpp/broker/src/Queue.cpp
+++ b/cpp/broker/src/Queue.cpp
@@ -122,7 +122,13 @@ void Queue::cancel(Consumer* c){
 }
 
 Message::shared_ptr Queue::dequeue(){
-
+    Locker locker(lock);
+    Message::shared_ptr msg;
+    if(!messages.empty()){
+        msg = messages.front();
+        messages.pop();
+    }
+    return msg;
 }
 
 u_int32_t Queue::purge(){