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 sessionKeyList = new ArrayList<>(messageDO.getSessionKeys()); - messageDO.setSessionKeys(sessionKeyList); - + String str = JSONUtil.toJsonStr(messageDO); stringRedisTemplate.convertAndSend(RedisSseEmitterMessageListener.CHANNEL, str); }