@@ -86,7 +86,7 @@ public class ChannelManager {
86
86
private final boolean maxConnectionsPerHostEnabled ;
87
87
private final ConcurrentHashMap <String , Semaphore > freeChannelsPerHost ;
88
88
private final ConcurrentHashMap <Integer , String > channelId2KeyPool ;
89
- private final long handshakeTimeoutInMillis ;
89
+ private final long handshakeTimeout ;
90
90
private final Timer nettyTimer ;
91
91
92
92
private final ClientSocketChannelFactory socketChannelFactory ;
@@ -148,7 +148,7 @@ public boolean remove(Object o) {
148
148
channelId2KeyPool = null ;
149
149
}
150
150
151
- handshakeTimeoutInMillis = nettyConfig .getHandshakeTimeoutInMillis ();
151
+ handshakeTimeout = nettyConfig .getHandshakeTimeout ();
152
152
153
153
if (nettyConfig .getSocketChannelFactory () != null ) {
154
154
socketChannelFactory = nettyConfig .getSocketChannelFactory ();
@@ -360,7 +360,7 @@ public SslHandler createSslHandler(String peerHost, int peerPort) throws General
360
360
sslEngine .setUseClientMode (true );
361
361
}
362
362
363
- return handshakeTimeoutInMillis > 0 ? new SslHandler (sslEngine , getDefaultBufferPool (), false , nettyTimer , handshakeTimeoutInMillis )
363
+ return handshakeTimeout > 0 ? new SslHandler (sslEngine , getDefaultBufferPool (), false , nettyTimer , handshakeTimeout )
364
364
: new SslHandler (sslEngine );
365
365
}
366
366
0 commit comments