diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2012-06-08 20:08:34 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2012-06-08 20:08:34 +0000 |
| commit | d0c175b6c729d87d0a288ec048dd80ccb66cc1b2 (patch) | |
| tree | 92eddf5251ff288af7642c02a2857a364ef59fa7 /java | |
| parent | cf2951b42f138ba405ecdd7bbb8ccb96d7ddde0b (diff) | |
| download | qpid-python-d0c175b6c729d87d0a288ec048dd80ccb66cc1b2.tar.gz | |
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
Diffstat (limited to 'java')
| -rw-r--r-- | java/common/src/main/java/org/apache/qpid/transport/network/io/IoNetworkTransport.java | 8 |
1 files changed, 4 insertions, 4 deletions
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<ByteBuffer> 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) { |