From 2d1f8cd6dbb4ebb78433420970028d867d0e729b Mon Sep 17 00:00:00 2001
From: jackshenonly <253170334@qq.com>
Date: Thu, 6 Jun 2024 10:03:43 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4Sse=20Redis=20=E5=88=86?=
 =?UTF-8?q?=E5=8F=91=E5=99=A8=E4=B8=AD=E7=9A=84=E5=86=97=E4=BD=99=E4=BB=A3?=
 =?UTF-8?q?=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../pigx/common/sse/distribute/RedisMessageDistributor.java  | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java
index 4e23f3743..8fd05e312 100644
--- a/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java
+++ b/pigx-common/pigx-common-sse/src/main/java/com/pig4cloud/pigx/common/sse/distribute/RedisMessageDistributor.java
@@ -24,10 +24,7 @@ public class RedisMessageDistributor implements MessageDistributor {
 	 */
 	@Override
 	public void distribute(MessageDO messageDO) {
-		// 包装 sessionKey 适配分布式多环境
-		List<Object> sessionKeyList = new ArrayList<>(messageDO.getSessionKeys());
-		messageDO.setSessionKeys(sessionKeyList);
-
+		
 		String str = JSONUtil.toJsonStr(messageDO);
 		stringRedisTemplate.convertAndSend(RedisSseEmitterMessageListener.CHANNEL, str);
 	}