diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-03-26 18:22:37 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2014-03-26 18:22:37 +0100 |
| commit | b6071e227819f54943933ed7a4ec0eaa4934ba4e (patch) | |
| tree | 54d9d22db644f2216a692aa5bc52e7345f61246b /src/InputReader.h | |
| parent | d43c72adb60395ea20550d49d0310aebbdca53a3 (diff) | |
| download | dabmod-b6071e227819f54943933ed7a4ec0eaa4934ba4e.tar.gz dabmod-b6071e227819f54943933ed7a4ec0eaa4934ba4e.tar.bz2 dabmod-b6071e227819f54943933ed7a4ec0eaa4934ba4e.zip | |
Change ZMQ input message format
Diffstat (limited to 'src/InputReader.h')
| -rw-r--r-- | src/InputReader.h | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/InputReader.h b/src/InputReader.h index 6a7d7c3..164c5ac 100644 --- a/src/InputReader.h +++ b/src/InputReader.h @@ -135,7 +135,7 @@ class InputFileReader : public InputReader struct InputZeroMQThreadData { - ThreadsafeQueue<zmq::message_t*> *in_messages; + ThreadsafeQueue<uint8_t*> *in_messages; std::string uri; }; @@ -191,7 +191,7 @@ class InputZeroMQReader : public InputReader std::string uri_; InputZeroMQWorker worker_; - ThreadsafeQueue<zmq::message_t*> in_messages_; + ThreadsafeQueue<uint8_t*> in_messages_; struct InputZeroMQThreadData workerdata_; }; |