From 10c430ab6795cd431e3908ae90aa428ef32fad8b Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Wed, 22 Apr 2020 13:18:20 +0200
Subject: [PATCH] Subscribe socket to all messages

---
 sf-buffer/src/sf_replay.cpp | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/sf-buffer/src/sf_replay.cpp b/sf-buffer/src/sf_replay.cpp
index 62d0505..b4c70e5 100644
--- a/sf-buffer/src/sf_replay.cpp
+++ b/sf-buffer/src/sf_replay.cpp
@@ -49,6 +49,10 @@ int main (int argc, char *argv[]) {
     auto socket = zmq_socket(ctx, ZMQ_PUSH);
     auto meta_socket = zmq_socket(ctx, ZMQ_SUB);
 
+    if (zmq_setsockopt(meta_socket, ZMQ_SUBSCRIBE, nullptr, 0) != 0) {
+        throw runtime_error(strerror (errno));
+    }
+
     int status = 0;
 
     int sndhwm = 1;