From 878fda30f6dde9fd3ce6f4232622d9b8f76b111f Mon Sep 17 00:00:00 2001 From: Redkale <22250530@qq.com> Date: Mon, 19 Jun 2017 13:45:16 +0800 Subject: [PATCH] --- test/org/redkale/test/http/WebSocketDesc.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/test/org/redkale/test/http/WebSocketDesc.java b/test/org/redkale/test/http/WebSocketDesc.java index a6103cc76..325b9bb06 100644 --- a/test/org/redkale/test/http/WebSocketDesc.java +++ b/test/org/redkale/test/http/WebSocketDesc.java @@ -11,7 +11,6 @@ import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.stream.Stream; import org.redkale.convert.json.JsonConvert; -import org.redkale.net.*; import org.redkale.net.http.*; /** @@ -79,9 +78,6 @@ public interface WebSocketDesc { //创建userid, null表示异常, 必须实现该方法 /* protected abstract */ G createUserid(); - //标记为@WebSocketBinary才需要重写此方法 - public void onRead(AsyncConnection channel); - //WebSokcet连接成功后的回调方法 public void onConnected(); @@ -94,6 +90,9 @@ public interface WebSocketDesc { //接收到消息的回调方法 public void onMessage(T message, boolean last); + //接收到文本消息的回调方法 + public void onMessage(String message, boolean last); + //接收到二进制消息的回调方法 public void onMessage(byte[] bytes, boolean last);