diff --git a/src/router.cpp b/src/router.cpp index 29e53cdb..545a25f8 100644 --- a/src/router.cpp +++ b/src/router.cpp @@ -326,6 +326,8 @@ int zmq::router_t::xrecv (msg_t *msg_) errno_assert (rc == 0); memcpy (msg_->data (), identity.data (), identity.size ()); msg_->set_flags (msg_t::more); + if (prefetched_msg.metadata()) + msg_->set_metadata(prefetched_msg.metadata()); identity_sent = true; }