From 3d11a95a29239179627ec94fa993d4d4083e1eea Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Thu, 31 May 2018 09:13:15 +0800
Subject: [PATCH]

---
 src/org/redkale/net/http/WebSocketRunner.java | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/src/org/redkale/net/http/WebSocketRunner.java b/src/org/redkale/net/http/WebSocketRunner.java
index 8ad807b28..6a2d1ccb9 100644
--- a/src/org/redkale/net/http/WebSocketRunner.java
+++ b/src/org/redkale/net/http/WebSocketRunner.java
@@ -290,18 +290,20 @@ class WebSocketRunner implements Runnable {
                 @Override
                 public void failed(Throwable exc, ByteBuffer[] attachments) {
                     writing.set(false);
+                    futureResult.complete(RETCODE_SENDEXCEPTION);
+                    closeRunner(RETCODE_SENDEXCEPTION, "websocket send message failed on CompletionHandler");
                     if (exc != null) {
                         context.getLogger().log(Level.FINE, "WebSocket sendMessage on CompletionHandler failed, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreatetime()) / 1000 + " seconds", exc);
                     }
-                    closeRunner(RETCODE_SENDEXCEPTION, "websocket send message failed on CompletionHandler");
 
                 }
             });
         } catch (Exception t) {
             writing.set(false);
-            context.getLogger().log(Level.FINE, "WebSocket sendMessage abort, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreatetime()) / 1000 + " seconds", t);
-            closeRunner(RETCODE_SENDEXCEPTION, "websocket send message failed on channel.write");
             futureResult.complete(RETCODE_SENDEXCEPTION);
+            closeRunner(RETCODE_SENDEXCEPTION, "websocket send message failed on channel.write");
+            context.getLogger().log(Level.FINE, "WebSocket sendMessage abort, force to close channel, live " + (System.currentTimeMillis() - webSocket.getCreatetime()) / 1000 + " seconds", t);
+
         }
         return futureResult;
     }