From 0792c2a65171eb7a763ac74cd4546552b7e0c756 Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 27 May 2021 17:21:27 +0800 Subject: [PATCH] modify --- src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java | 3 +-- 1 files changed, 1 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java b/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java index 0f6716c..8511435 100644 --- a/src/main/java/com/xcong/excoin/netty/logic/WebSocketLogic.java +++ b/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); } } -- Gitblit v1.9.1