Multi-hop REQ/REP, part I., tracerouting switched on on XREP socket

1 files changed, 6 insertions, 0 deletions

diff --git a/src/zmq_init.cpp b/src/zmq_init.cpp
index 37aafe6..9492caa 100644
--- a/src/zmq_init.cpp
+++ b/src/zmq_init.cpp
@@ -76,6 +76,12 @@ bool zmq::zmq_init_t::write (::zmq_msg_t *msg_)
         zmq_msg_size (msg_));
     received = true;
 
+    //  Once the initial handshaking is over, XREP sockets should start
+    //  tracerouting individual messages.
+    if (options.type == ZMQ_XREP)
+        engine->traceroute ((unsigned char*) peer_identity.data (),
+            peer_identity.size ());
+
     return true;
 }