From b6cefe8c2d23e92787629c401dc5adf6ff6db426 Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Wed, 21 Jun 2017 17:34:08 +0800 Subject: [PATCH] --- src/org/redkale/net/http/WebSocketRunner.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/org/redkale/net/http/WebSocketRunner.java b/src/org/redkale/net/http/WebSocketRunner.java index c9f2380d4..633b5e3c2 100644 --- a/src/org/redkale/net/http/WebSocketRunner.java +++ b/src/org/redkale/net/http/WebSocketRunner.java @@ -280,7 +280,7 @@ class WebSocketRunner implements Runnable { QueueEntry entry = queue.poll(); if (entry != null) { future = entry.future; - ByteBuffer[] buffers = packet.sendBuffers != null ? packet.duplicateSendBuffers() : packet.encode(context.getBufferSupplier()); + ByteBuffer[] buffers = entry.packet.sendBuffers != null ? entry.packet.duplicateSendBuffers() : entry.packet.encode(context.getBufferSupplier()); lastSendTime = System.currentTimeMillis(); channel.write(buffers, buffers, this); }