From e8c274301aca0bca1b7d1e6086cf29af4645732e Mon Sep 17 00:00:00 2001
From: "Matthias P. Braendli" <matthias.braendli@mpb.li>
Date: Fri, 21 Feb 2014 10:49:42 +0100
Subject: zmq input improvements

---
 src/InputReader.h | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

(limited to 'src/InputReader.h')

diff --git a/src/InputReader.h b/src/InputReader.h
index ae36899..de8fb78 100644
--- a/src/InputReader.h
+++ b/src/InputReader.h
@@ -143,15 +143,14 @@ class InputZeroMQWorker
 {
     public:
         InputZeroMQWorker() :
-            zmqcontext(1), subscriber(zmqcontext, ZMQ_SUB) {}
+            zmqcontext(1)  {}
 
         void Start(struct InputZeroMQThreadData* workerdata);
         void Stop();
     private:
         void RecvProcess(struct InputZeroMQThreadData* workerdata);
         bool running;
-        zmq::context_t zmqcontext;
-        zmq::socket_t subscriber;
+        zmq::context_t zmqcontext; // is thread-safe
         boost::thread recv_thread;
 };
 
-- 
cgit v1.2.3