added waiting for message

Author: KolorowyAleksander

client-example/src/main.cpp

@@ -61,12 +61,8 @@ int main(int argc, char* argv[]) {
     try {
       Connection connection(broker, port);
       connection.queueBind("timed_queue_test");
-      while (true) {
-        std::vector<uint8_t> v = connection.collect();
-        if (v.size() != 0) {
-          std::cout << "recieved message from timed queue!" << std::endl;
-        }
-      }
+      std::vector<uint8_t> v = connection.collect();
+      std::cout << "recieved message from timed queue!" << std::endl;
     } catch (PostmanException e) {
       std::cout << e.what() << std::endl;
     }

mailbox/src/ConnectionReciever.cpp

@@ -10,6 +10,8 @@
 #include <algorithm>
 #include <cerrno>
 #include <vector>
+#include <thread>
+#include <chrono>
 
 const int queueNameSize = 255;
 const int keySize = 255;
@@ -119,7 +121,16 @@ void ConnectionReciever::handleMessageCollection() {
     return;
   }
 
-  std::vector<uint8_t> message = _queue->collect();
+  bool waiting = true;
+  std::vector<uint8_t> message;
+  while(waiting) {
+    message = _queue->collect();
+    if (message.size() != 0) {
+      waiting = false;
+    } else {
+      std::this_thread::sleep_for(std::chrono::milliseconds(100));
+    }
+  }
   uint64_t size = message.size();
 
   if (write(_socket, &size, 8) < 0) {