From 86b452312e6828b3cb141d26e15b4f93ac2c9bb0 Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Thu, 9 Apr 2020 13:37:51 +0200
Subject: [PATCH] Change ZMQ to SUB

---
 core-writer/src/receiver/ZmqReceiver.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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)
 {