From f01c0a741d281a9c771ec94244dad65e1b36b61c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=9C=B0=E5=B9=B3=E7=BA=BF?= <22250530@qq.com>
Date: Thu, 13 Aug 2015 09:36:38 +0800
Subject: [PATCH]

---
 src/com/wentch/redkale/net/Transport.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/com/wentch/redkale/net/Transport.java b/src/com/wentch/redkale/net/Transport.java
index 17fbd2e86..5a35bec60 100644
--- a/src/com/wentch/redkale/net/Transport.java
+++ b/src/com/wentch/redkale/net/Transport.java
@@ -107,9 +107,11 @@ public final class Transport {
                         p = i;
                         addr = remoteAddres[i];
                         BlockingQueue<AsyncConnection> queue = connPool.get(addr);
-                        if (queue != null && queue.isEmpty()) {
-                            AsyncConnection conn = queue.poll();
-                            if (conn.isOpen()) return conn;
+                        if (queue != null && !queue.isEmpty()) {
+                            AsyncConnection conn;
+                            while ((conn = queue.poll()) != null) {
+                                if (conn.isOpen()) return conn;
+                            }
                         }
                         if (channel == null) channel = AsynchronousSocketChannel.open(group);
                         try {