From 5e60f18d3a68947f469346162deae7e65732ba50 Mon Sep 17 00:00:00 2001
From: Thomas Rodgers <trodgers@drw.com>
Date: Wed, 18 Feb 2015 11:17:41 -0600
Subject: [PATCH] Add connector.close() back

Needed if session->push() ever fails
---
 src/stream_engine.cpp | 1 +
 1 file changed, 1 insertion(+)

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