Removed producer wait loop

0f0cff91 · Christopher Reis · 811a38a6 · 0f0cff91
Commit 0f0cff91 authored Feb 16, 2017 by Christopher Reis
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 4 deletions

KafkaConnection.cpp src/KafkaConnection.cpp +4 -4

No files found.
--- a/src/KafkaConnection.cpp
+++ b/src/KafkaConnection.cpp
@@ -330,10 +330,10 @@ void KafkaConnection::mwPublish(const Message& message, const Config& config)
     producer->poll(0);
   }

-   while (run && producer->outq_len() > 0) {
-     std::cerr << "Waiting for " << producer->outq_len() << std::endl;
-     producer->poll(250);
-   }
+  //  while (run && producer->outq_len() > 0) {
+  //    std::cerr << "Waiting for " << producer->outq_len() << std::endl;
+  //    producer->poll(250);
+  //  }

 	GMSEC_DEBUG << "gmsec_kafka:KafkaConnection::Publish(things)" << '\n' << message.toXML() ;
 }