diff --git a/src/stream_engine.cpp b/src/stream_engine.cpp
index cf2e3a61..915b6965 100644
--- a/src/stream_engine.cpp
+++ b/src/stream_engine.cpp
@@ -210,6 +210,7 @@ void zmq::stream_engine_t::plug (io_thread_t *io_thread_,
             connector.set_metadata(metadata);
         push_msg_to_session (&connector);
         session->flush ();
+        connector.close();
     }
     else {
         // start optional timer, to prevent handshake hanging on no input