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

Browse Source
This commit is contained in:
Redkale
2020-01-08 10:42:08 +08:00
parent 06bb5180cf
commit 66e1f58879
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
test/org/redkale/test/websocket/VideoWebSocketServlet.java
View File

@@ -65,7 +65,7 @@ public class VideoWebSocketServlet extends WebSocketServlet {
} }
@Override @Override
public void onConnected() { public CompletableFuture onConnected() {
if (repeat) { if (repeat) {
super.close(); super.close();
} else { } else {
@@ -82,6 +82,7 @@ public class VideoWebSocketServlet extends WebSocketServlet {
String msg = ("{'type':'discover_user','user':{'userid':'" + this.getSessionid() + "','username':'" + users.get(this.getSessionid()) + "'}}").replace('\'', '"'); String msg = ("{'type':'discover_user','user':{'userid':'" + this.getSessionid() + "','username':'" + users.get(this.getSessionid()) + "'}}").replace('\'', '"');
super.broadcastMessage(msg); super.broadcastMessage(msg);
} }
return null;
} }
@Override @Override
@@ -91,10 +92,10 @@ public class VideoWebSocketServlet extends WebSocketServlet {
} }
@Override @Override
public void onClose(int code, String reason) { public CompletableFuture onClose(int code, String reason) {
sessions.remove(this.getSessionid()); sessions.remove(this.getSessionid());
String msg = ("{'type':'remove_user','user':{'userid':'" + this.getSessionid() + "','username':'" + users.get(this.getSessionid()) + "'}}").replace('\'', '"'); String msg = ("{'type':'remove_user','user':{'userid':'" + this.getSessionid() + "','username':'" + users.get(this.getSessionid()) + "'}}").replace('\'', '"');
super.broadcastMessage(msg); return super.broadcastMessage(msg);
} }
@Override @Override