diff --git a/src/stream_engine.cpp b/src/stream_engine.cpp index 03c1f9a7..f154094b 100644 --- a/src/stream_engine.cpp +++ b/src/stream_engine.cpp @@ -869,7 +869,7 @@ int zmq::stream_engine_t::push_msg_to_session (msg_t *msg_) } int zmq::stream_engine_t::push_raw_msg_to_session (msg_t *msg_) { - if (metadata) + if (metadata && metadata != msg_->metadata()) msg_->set_metadata(metadata); return push_msg_to_session(msg_); }