支持推流和拉流代理通道状态变化发送通知

648540858

2023-04-23 b944f8867c78dbe6dd4704115b48beb9f6dc12d9

 src/main/java/com/genersoft/iot/vmp/storager/impl/RedisCatchStorageImpl.java

@@ -24,6 +24,7 @@
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;

import java.util.*;
@@ -42,6 +43,9 @@

    @Autowired
    private RedisTemplate<Object, Object> redisTemplate;

    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    @Override
    public Long getCSEQ() {
@@ -913,7 +917,7 @@
            msg.append(":").append(channelId);
        }
        msg.append(" ").append(online? "ON":"OFF");

        redisTemplate.convertAndSend(key, msg.toString());
        // 使用 RedisTemplate<Object, Object> 发送字符串消息会导致发送的消息多带了双引号
        stringRedisTemplate.convertAndSend(key, msg.toString());
    }
}