From d0c175b6c729d87d0a288ec048dd80ccb66cc1b2 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Fri, 8 Jun 2012 20:08:34 +0000 Subject: QPID-4047 : [Java] Add timeout to socket connect git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1348224 13f79535-47bb-0310-9956-ffa450edef68 --- .../org/apache/qpid/transport/network/io/IoNetworkTransport.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'java/common') diff --git a/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkTransport.java b/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkTransport.java index 56f6989aae..dfb318b80c 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkTransport.java +++ b/java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkTransport.java @@ -47,10 +47,10 @@ import org.slf4j.LoggerFactory; public class IoNetworkTransport implements OutgoingNetworkTransport, IncomingNetworkTransport { private static final org.slf4j.Logger LOGGER = LoggerFactory.getLogger(IoNetworkTransport.class); + private static final int TIMEOUT = 60000; private Socket _socket; private IoNetworkConnection _connection; - private long _timeout = 60000; private AcceptingThread _acceptor; public NetworkConnection connect(ConnectionSettings settings, Receiver delegate, SSLContext sslContext) @@ -75,7 +75,7 @@ public class IoNetworkTransport implements OutgoingNetworkTransport, IncomingNet InetAddress address = InetAddress.getByName(settings.getHost()); - _socket.connect(new InetSocketAddress(address, settings.getPort())); + _socket.connect(new InetSocketAddress(address, settings.getPort()), TIMEOUT); } catch (SocketException e) { @@ -88,7 +88,7 @@ public class IoNetworkTransport implements OutgoingNetworkTransport, IncomingNet try { - _connection = new IoNetworkConnection(_socket, delegate, sendBufferSize, receiveBufferSize, _timeout); + _connection = new IoNetworkConnection(_socket, delegate, sendBufferSize, receiveBufferSize, TIMEOUT); _connection.start(); } catch(Exception e) @@ -224,7 +224,7 @@ public class IoNetworkTransport implements OutgoingNetworkTransport, IncomingNet ProtocolEngine engine = _factory.newProtocolEngine(); - NetworkConnection connection = new IoNetworkConnection(socket, engine, sendBufferSize, receiveBufferSize, _timeout); + NetworkConnection connection = new IoNetworkConnection(socket, engine, sendBufferSize, receiveBufferSize, TIMEOUT); if(_sslContext != null) { -- cgit v1.2.1