From 2b7676449dc0ed2d6e1d86c80dace677cce1d19b Mon Sep 17 00:00:00 2001 From: Redkale <8730487+redkale@users.noreply.github.com> Date: Thu, 30 Jul 2020 17:57:31 +0800 Subject: [PATCH] --- src/org/redkale/net/Transport.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/src/org/redkale/net/Transport.java b/src/org/redkale/net/Transport.java index a79eb278f..4825274dd 100644 --- a/src/org/redkale/net/Transport.java +++ b/src/org/redkale/net/Transport.java @@ -10,7 +10,6 @@ import java.lang.ref.WeakReference; import java.net.*; import java.nio.ByteBuffer; import java.nio.channels.*; -import java.sql.SQLException; import java.util.*; import java.util.concurrent.*; import java.util.concurrent.atomic.*; @@ -225,7 +224,7 @@ public final class Transport { protected CompletableFuture pollAsync(TransportNode node, SocketAddress addr, Supplier> func, final int count) { if (count >= 5) { CompletableFuture future = new CompletableFuture<>(); - future.completeExceptionally(new SQLException("create AsyncConnection error")); + future.completeExceptionally(new RuntimeException("create AsyncConnection error")); return future; } final BlockingQueue queue = node.conns;