1 files changed, 0 insertions, 10 deletions
diff --git a/src/pgm_sender.cpp b/src/pgm_sender.cpp
index f68c044..dde6284 100644
--- a/src/pgm_sender.cpp
+++ b/src/pgm_sender.cpp
@@ -92,16 +92,6 @@ void xs::pgm_sender_t::plug (io_thread_t *io_thread_, session_base_t *session_)
 
     //  Set POLLOUT for downlink_socket_handle.
     set_pollout (handle);
-
-    //  PGM is not able to pass subscriptions upstream, thus we have no idea
-    //  what messages are peers interested in. Because of that we have to
-    //  subscribe for all the messages.
-    msg_t msg;
-    msg.init_size (1);
-    *(unsigned char*) msg.data () = 1;
-    int rc = session_->write (&msg);
-    errno_assert (rc == 0);
-    session_->flush ();
 }
 
 void xs::pgm_sender_t::unplug ()