From 43b5b3444c5ea54fa17eab2e03b7e00c022f33b4 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sun, 24 Jul 2011 18:30:48 +0200 Subject: PGM subscription forwarding fixed PGM when using in XPUB socket has to subscribe for all the messages as it has no idea what the subscribers are interesred in. This generic subscribe message was malformed. Fixed. Signed-off-by: Martin Sustrik --- src/pgm_sender.cpp | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'src/pgm_sender.cpp') diff --git a/src/pgm_sender.cpp b/src/pgm_sender.cpp index d2419ea..79d4e32 100644 --- a/src/pgm_sender.cpp +++ b/src/pgm_sender.cpp @@ -94,7 +94,8 @@ void zmq::pgm_sender_t::plug (io_thread_t *io_thread_, session_t *session_) // what messages are peers interested in. Because of that we have to // subscribe for all the messages. msg_t msg; - msg.init (); + msg.init_size (1); + *(unsigned char*) msg.data () = 1; bool ok = session_->write (&msg); zmq_assert (ok); session_->flush (); -- cgit v1.2.3