diff --git a/sf-buffer/src/sf_replay.cpp b/sf-buffer/src/sf_replay.cpp
index 1e18404..e64669c 100644
--- a/sf-buffer/src/sf_replay.cpp
+++ b/sf-buffer/src/sf_replay.cpp
@@ -47,11 +47,11 @@ int main (int argc, char *argv[]) {
 
     auto ctx = zmq_ctx_new();
     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));
-    }
+    auto meta_socket = zmq_socket(ctx, ZMQ_PULL);
+//
+//    if (zmq_setsockopt(meta_socket, ZMQ_SUBSCRIBE, nullptr, 0) != 0) {
+//        throw runtime_error(strerror (errno));
+//    }
 
     int status = 0;
 
diff --git a/sf-writer/sf_h5_writer.cpp b/sf-writer/sf_h5_writer.cpp
index 3839966..da26db8 100644
--- a/sf-writer/sf_h5_writer.cpp
+++ b/sf-writer/sf_h5_writer.cpp
@@ -36,7 +36,7 @@ int main (int argc, char *argv[])
     zmq_ctx_set (ctx, ZMQ_IO_THREADS, 16);
 
     auto socket = zmq_socket(ctx, ZMQ_PULL);
-    auto meta_socket = zmq_socket(ctx, ZMQ_PUB);
+    auto meta_socket = zmq_socket(ctx, ZMQ_PUSH);
 
     int rcvhwm = 1000;
     if (zmq_setsockopt(socket, ZMQ_RCVHWM, &rcvhwm, sizeof(rcvhwm)) != 0) {