diff --git a/core-buffer/src/WriterZmqReceiver.cpp b/core-buffer/src/WriterZmqReceiver.cpp
index 010bc9e..66e0cac 100644
--- a/core-buffer/src/WriterZmqReceiver.cpp
+++ b/core-buffer/src/WriterZmqReceiver.cpp
@@ -33,7 +33,7 @@ WriterZmqReceiver::WriterZmqReceiver(
         ipc_addr << ipc_prefix << i;
         const auto ipc = ipc_addr.str();
 
-        if (zmq_bind(sockets_[i], ipc.c_str()) != 0) {
+        if (zmq_connect(sockets_[i], ipc.c_str()) != 0) {
             throw runtime_error(zmq_strerror(errno));
         }
     }