This commit is contained in:
@@ -148,7 +148,7 @@ public final class Transport {
|
|||||||
if (channel == null) channel = AsynchronousSocketChannel.open(group);
|
if (channel == null) channel = AsynchronousSocketChannel.open(group);
|
||||||
|
|
||||||
try {
|
try {
|
||||||
channel.connect(addr).get(1, TimeUnit.SECONDS);
|
channel.connect(addr).get(2, TimeUnit.SECONDS);
|
||||||
break;
|
break;
|
||||||
} catch (Exception iex) {
|
} catch (Exception iex) {
|
||||||
iex.printStackTrace();
|
iex.printStackTrace();
|
||||||
|
|||||||
Reference in New Issue
Block a user