代码优化

yangys

2024-05-18 cc0bdfb33ef638dfafe3185c92c7076d815e1c9b

 smart-starter-websocket/src/main/java/com/qianwen/core/websocket/distribute/RedisMessageDistributor.java

@@ -10,7 +10,6 @@
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.data.redis.core.StringRedisTemplate;

/* loaded from: blade-starter-websocket-9.3.0.0-SNAPSHOT.jar:org/springblade/core/websocket/distribute/RedisMessageDistributor.class */
public class RedisMessageDistributor implements MessageDistributor {
    private final StringRedisTemplate stringRedisTemplate;

@@ -18,7 +17,7 @@
        this.stringRedisTemplate = stringRedisTemplate;
    }

    @Override // com.qianwen.core.websocket.distribute.MessageDistributor
    @Override
    public void distribute(MessageDO messageDO) {
        String host;
        int port;
@@ -40,7 +39,7 @@
        if (Func.isNotEmpty(messageDO.getSessionKeys())) {
            String str = host;
            int i = port;
            List<Object> sessionKeyList = (List) messageDO.getSessionKeys().stream().map(key -> {
            List<Object> sessionKeyList = messageDO.getSessionKeys().stream().map(key -> {
                return String.format("%s:%s:%s", str, Integer.valueOf(i), key);
            }).collect(Collectors.toList());
            messageDO.setSessionKeys(sessionKeyList);