From 097ae701c128b3ee7c8dfa45d7aa94801c09371f Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Thu, 29 Mar 2018 11:18:22 +0800 Subject: [PATCH] --- src/org/redkale/net/Transport.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) diff --git a/src/org/redkale/net/Transport.java b/src/org/redkale/net/Transport.java index dcd018176..ccf3e3e18 100644 --- a/src/org/redkale/net/Transport.java +++ b/src/org/redkale/net/Transport.java @@ -268,12 +268,7 @@ public final class Transport { taddr.enable = true; AsyncConnection asyncConn = AsyncConnection.create(channel, attachment.address, factory.readTimeoutSecond, factory.writeTimeoutSecond); if (future.isDone()) { - if (!attachment.conns.offer(asyncConn)) { - try { - channel.close(); - } catch (Exception e) { - } - } + if (!attachment.conns.offer(asyncConn)) asyncConn.dispose(); } else { future.complete(asyncConn); }