删除Sse Redis 分发器中的冗余代码

This commit is contained in:
jackshenonly committed 2024-06-06 10:03:43 +08:00
1 parent 45fc19a5b2
commit 2d1f8cd6db
1 file changed
+1 -4
@@ -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);
}