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