diff options
| author | Matthias P. Braendli <matthias.braendli@mpb.li> | 2021-01-16 08:06:09 +0100 |
|---|---|---|
| committer | Matthias P. Braendli <matthias.braendli@mpb.li> | 2021-01-16 08:06:09 +0100 |
| commit | d14814a92377084177753c7a60d83a9307ad0672 (patch) | |
| tree | 3b901eed7eaacc07341d16dbcd0db0d60951a5e0 /src/OutputZeroMQ.cpp | |
| parent | 0efb3830dcd441ffdb53ebe69f2dc2886614fb8b (diff) | |
| download | dabmod-d14814a92377084177753c7a60d83a9307ad0672.tar.gz dabmod-d14814a92377084177753c7a60d83a9307ad0672.tar.bz2 dabmod-d14814a92377084177753c7a60d83a9307ad0672.zip | |
Update common code to latest, update zmq.hpp and adapt
Diffstat (limited to 'src/OutputZeroMQ.cpp')
| -rw-r--r-- | src/OutputZeroMQ.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/OutputZeroMQ.cpp b/src/OutputZeroMQ.cpp index 69f4aa1..373081b 100644 --- a/src/OutputZeroMQ.cpp +++ b/src/OutputZeroMQ.cpp @@ -68,10 +68,10 @@ int OutputZeroMQ::process(Buffer* dataIn) if (m_type == ZMQ_REP) { // A ZMQ_REP socket requires a request first zmq::message_t msg; - m_zmq_sock.recv(&msg); + m_zmq_sock.recv(msg, zmq::recv_flags::none); } - m_zmq_sock.send(dataIn->getData(), dataIn->getLength()); + m_zmq_sock.send(zmq::const_buffer{dataIn->getData(), dataIn->getLength()}); return dataIn->getLength(); } |