From 7b5b0f34ff3c6eb145fa4b56ce1e213a4881cfd6 Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Wed, 30 May 2018 18:54:02 +0800
Subject: [PATCH]

---
 src/org/redkale/net/Response.java | 14 +++++++++-----
 1 file changed, 9 insertions(+), 5 deletions(-)

diff --git a/src/org/redkale/net/Response.java b/src/org/redkale/net/Response.java
index 9439f80bf..28d7715c4 100644
--- a/src/org/redkale/net/Response.java
+++ b/src/org/redkale/net/Response.java
@@ -251,11 +251,15 @@ public abstract class Response<C extends Context, R extends Request<C>> {
             }
             this.recycleListener = null;
         }
-        if (request.keepAlive && channel != null && channel.isOpen()) {
-            AsyncConnection conn = removeChannel();
-            this.recycle();
-            this.prepare();
-            new PrepareRunner(context, conn, null, this).run();
+        if (request.keepAlive && channel != null) {
+            if (channel.isOpen()) {
+                AsyncConnection conn = removeChannel();
+                this.recycle();
+                this.prepare();
+                new PrepareRunner(context, conn, null, this).run();
+            } else {
+                channel.dispose();
+            }
         } else {
             this.context.responsePool.accept(this);
         }