diff --git a/src/pgm_receiver.cpp b/src/pgm_receiver.cpp index b5d55511..030c293c 100644 --- a/src/pgm_receiver.cpp +++ b/src/pgm_receiver.cpp @@ -274,6 +274,7 @@ void zmq::pgm_receiver_t::timer_event (int token) void zmq::pgm_receiver_t::drop_subscriptions () { msg_t msg; + msg.init (); while (session->pull_msg (&msg)) msg.close (); }