根据redis消息更新推流列表

jiang

2022-08-18 8f77d0c25cdd37d4cc96c923b46ae28607bae51d

 src/main/java/com/genersoft/iot/vmp/conf/RedisConfig.java

@@ -43,6 +43,9 @@
   @Autowired

   private RedisPushStreamStatusMsgListener redisPushStreamStatusMsgListener;



   @Autowired

   private RedisPushStreamListMsgListener redisPushStreamListMsgListener;



   @Bean

   public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {

      RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();

@@ -80,6 +83,7 @@
      container.addMessageListener(redisStreamMsgListener, new PatternTopic(VideoManagerConstants.WVP_MSG_STREAM_CHANGE_PREFIX + "PUSH"));

      container.addMessageListener(redisGbPlayMsgListener, new PatternTopic(RedisGbPlayMsgListener.WVP_PUSH_STREAM_KEY));

      container.addMessageListener(redisPushStreamStatusMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_PUSH_STREAM_STATUS_CHANGE));

      container.addMessageListener(redisPushStreamListMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_PUSH_STREAM_LIST_CHANGE));

        return container;

    }