1 files changed, 3 insertions, 3 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaNetworkTransport.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaNetworkTransport.java
index 5c84f405e2..2010b2dd93 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaNetworkTransport.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/network/mina/MinaNetworkTransport.java
@@ -108,7 +108,7 @@ public class MinaNetworkTransport implements IncomingNetworkTransport, OutgoingN
         if (_settings.getProtocol().equalsIgnoreCase(Transport.TCP))
         {
 	        _address = new InetSocketAddress(_settings.getHost(), _settings.getPort());
-	        _connector = new SocketConnector(_threads, _executor); // non-blocking connector
+	        _connector = new SocketConnector(1, _executor); // non-blocking connector
         }
         else if (_settings.getProtocol().equalsIgnoreCase(Transport.UDP))
         {
@@ -133,7 +133,7 @@ public class MinaNetworkTransport implements IncomingNetworkTransport, OutgoingN
                                                    "with 'socket://<SocketID>' transport");
             }
 	        _address = socket.getRemoteSocketAddress();
-            _connector = new ExistingSocketConnector(_threads, _executor);
+            _connector = new ExistingSocketConnector(1, _executor);
             ((ExistingSocketConnector) _connector).setOpenSocket(socket);
         }
         else
@@ -271,7 +271,7 @@ public class MinaNetworkTransport implements IncomingNetworkTransport, OutgoingN
         {
             _receiver.closed();
         }
-        if (_session != null && _session.isConnected())
+        if (_session != null)
         {
             _session.close();
         }