diff --git a/core-writer/src/receiver/ZmqReceiver.cpp b/core-writer/src/receiver/ZmqReceiver.cpp
index 226fd07..e8bda73 100644
--- a/core-writer/src/receiver/ZmqReceiver.cpp
+++ b/core-writer/src/receiver/ZmqReceiver.cpp
@@ -56,7 +56,7 @@ ZmqReceiver::ZmqReceiver(
         const int n_io_threads) :
             header_values_type_(header_values_type),
             context_(n_io_threads),
-            socket_(context_, ZMQ_PULL),
+            socket_(context_, ZMQ_SUB),
             message_header_(config::zmq_buffer_size_header),
             message_data_(config::zmq_buffer_size_data)
 {