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();
 }