聊天室信息发送
This commit is contained in:
parent
082aedafdf
commit
b04783a3ba
|
|
@ -39,7 +39,7 @@ public class ChatRoom {
|
||||||
*/
|
*/
|
||||||
@OnOpen
|
@OnOpen
|
||||||
public void onOpen(Session session, @PathParam("roomId") String roomId) {
|
public void onOpen(Session session, @PathParam("roomId") String roomId) {
|
||||||
if (getRoomCache().createSuccess(roomId)) {
|
if (!getRoomCache().createSuccess(roomId)) {
|
||||||
this.sendMessage("无此房间,拒绝连接", session);
|
this.sendMessage("无此房间,拒绝连接", session);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue