1 files changed, 7 insertions, 1 deletions
diff --git a/perf/c/local_thr.c b/perf/c/local_thr.c
index 68d9ec6..9b94330 100644
--- a/perf/c/local_thr.c
+++ b/perf/c/local_thr.c
@@ -48,9 +48,15 @@ int main (int argc, char *argv [])
     ctx = zmq_init (1, 1);
     assert (ctx);
 
-    s = zmq_socket (ctx, ZMQ_P2P);
+    s = zmq_socket (ctx, ZMQ_SUB);
     assert (s);
 
+    rc = zmq_setsockopt (s, ZMQ_SUBSCRIBE , "*", 1);
+    assert (rc == 0);
+
+    //  Add your socket options here.
+    //  For example ZMQ_RATE, ZMQ_RECOVERY_IVL and ZMQ_MCAST_LOOP for PGM.
+
     rc = zmq_bind (s, bind_to);
     assert (rc == 0);