From c9cb095a9ba6c2c52490e92fd63a8eecb84167fd Mon Sep 17 00:00:00 2001
From: xiaoguangbin <xiaoguangbin>
Date: Mon, 23 Oct 2023 10:48:55 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E8=A7=A3=E5=86=B3gamma=E8=87=AA?=
 =?UTF-8?q?=E5=8A=A8=E5=A4=84=E7=90=86=E6=8E=A8=E9=80=81=E5=88=86=E6=9E=90?=
 =?UTF-8?q?=E8=BF=9B=E5=BA=A6=E4=BC=9A=E5=87=BA=E7=8E=B0userid=3Dnull?=
 =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/jeecg/modules/message/handle/AnalysisHandler.java     | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java
index b6fde5bf..a7bf1dee 100644
--- a/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java
+++ b/jeecg-module-system/jeecg-system-biz/src/main/java/org/jeecg/modules/message/handle/AnalysisHandler.java
@@ -1,6 +1,7 @@
 package org.jeecg.modules.message.handle;
 
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.ObjectUtils;
 import org.jeecg.common.base.BaseMap;
 import org.jeecg.common.constant.WebSocketHandlerConst;
 import org.jeecg.common.modules.redis.listener.JeecgRedisListener;
@@ -24,6 +25,9 @@ public class AnalysisHandler implements JeecgRedisListener {
 
     @Override
     public void onMessage(BaseMap message) {
+        if (ObjectUtils.isEmpty(message.get("userId"))) {
+            return;
+        }
         webSocket.sendMessage(message.get("userId").toString(), message.get("message"));
     }