From fee9813b90b53dc640783930fef66f07fe81be78 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=9C=B0=E5=B9=B3=E7=BA=BF?= <22250530@qq.com>
Date: Mon, 29 Jun 2015 11:15:51 +0800
Subject: [PATCH]

---
 src/com/wentch/redkale/net/http/WebSocketRunner.java | 9 +++++++++
 1 file changed, 9 insertions(+)

diff --git a/src/com/wentch/redkale/net/http/WebSocketRunner.java b/src/com/wentch/redkale/net/http/WebSocketRunner.java
index 7ea4095f0..a179a0279 100644
--- a/src/com/wentch/redkale/net/http/WebSocketRunner.java
+++ b/src/com/wentch/redkale/net/http/WebSocketRunner.java
@@ -78,7 +78,16 @@ public class WebSocketRunner implements Runnable {
                         readBuffer.flip();
                         try {
                             ByteBuffer[] exBuffers = null;
+                            if (!readBuffers.isEmpty()) {
+                                exBuffers = readBuffers.toArray(new ByteBuffer[readBuffers.size()]);
+                                readBuffers.clear();
+                            }
                             WebSocketPacket packet = coder.decode(readBuffer, exBuffers);
+                            if (exBuffers != null) {
+                                for (ByteBuffer b : exBuffers) {
+                                    context.offerBuffer(b);
+                                }
+                            }
                             if (packet == null) {
                                 if (debug) context.getLogger().log(Level.FINEST, "WebSocketRunner abort on decode WebSocketPacket, force to close channel");
                                 failed(null, attachment1);