lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Browse Source
This commit is contained in:
地平线
2015-09-10 09:13:30 +08:00
parent 09fca88606
commit 79ef805a42
1 changed files with 10 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/com/wentch/redkale/net/http/WebSocketRunner.java
View File

@@ -119,14 +119,18 @@ public class WebSocketRunner implements Runnable {
channel.read(readBuffer, null, this); channel.read(readBuffer, null, this);
} }
webSocket.group.setRecentWebSocket(webSocket); webSocket.group.setRecentWebSocket(webSocket);
try {
if (packet.type == PacketType.TEXT) { if (packet.type == PacketType.TEXT) {
webSocket.onMessage(packet.getPayload()); webSocket.onMessage(packet.getPayload());
} else if (packet.type == PacketType.BINARY) { } else if (packet.type == PacketType.BINARY) {
webSocket.onMessage(packet.getBytes()); webSocket.onMessage(packet.getBytes());
} }
} catch (Exception e) { } catch (Exception e) {
context.getLogger().log(Level.INFO, "WebSocket onMessage error (" + packet + ")", e);
}
} catch (Throwable t) {
closeRunner(); closeRunner();
if (debug) context.getLogger().log(Level.FINEST, "WebSocketRunner abort on read WebSocketPacket, force to close channel", e); if (debug) context.getLogger().log(Level.FINEST, "WebSocketRunner abort on read WebSocketPacket, force to close channel", t);
} }
} }