src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java | ●●●●● patch | view | raw | blame | history |
src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java
@@ -92,8 +92,6 @@ ResponseBean toRes = ResponseBean.ok(chat); res.setType(2); targetChannel.writeAndFlush(NettyTools.webSocketJson(toRes)); chatProducer.sendMsgHistory(chat); } else { // 在redis中保存用户未在线时,给该用户发送的消息条数 String key = AppContants.MSG_NOTICE + chat.getTargetId(); @@ -104,5 +102,6 @@ redisUtils.set(key, Integer.parseInt(value) + 1); } } chatProducer.sendMsgHistory(chat); } }