优化多wvp国标级联推流

648540858

2024-04-16 b4168c02cba462571dd3f5bdc1d0b1ffddbc938a

 src/main/java/com/genersoft/iot/vmp/conf/redis/RedisMsgListenConfig.java

@@ -29,12 +29,6 @@
   private RedisAlarmMsgListener redisAlarmMsgListener;

   @Autowired
   private RedisStreamMsgListener redisStreamMsgListener;

   @Autowired
   private RedisGbPlayMsgListener redisGbPlayMsgListener;

   @Autowired
   private RedisPushStreamStatusMsgListener redisPushStreamStatusMsgListener;

   @Autowired
@@ -44,7 +38,19 @@
   private RedisPushStreamResponseListener redisPushStreamResponseListener;

   @Autowired
   private RedisCloseStreamMsgListener redisCloseStreamMsgListener;

   @Autowired
   private RedisPushStreamCloseResponseListener redisPushStreamCloseResponseListener;

   @Autowired
   private RedisPlatformWaitPushStreamOnlineListener redisPlatformWaitPushStreamOnlineListener;

   @Autowired
   private RedisPlatformStartSendRtpListener redisPlatformStartSendRtpListener;

   @Autowired
   private RedisPlatformPushStreamOnlineLister redisPlatformPushStreamOnlineLister;


   /**
@@ -61,12 +67,14 @@
        container.setConnectionFactory(connectionFactory);
      container.addMessageListener(redisGPSMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_GPS));
      container.addMessageListener(redisAlarmMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_SUBSCRIBE_ALARM_RECEIVE));
      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));
      container.addMessageListener(redisPushStreamResponseListener, new PatternTopic(VideoManagerConstants.VM_MSG_STREAM_PUSH_RESPONSE));
      container.addMessageListener(redisCloseStreamMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_STREAM_PUSH_CLOSE));
      container.addMessageListener(redisPushStreamCloseResponseListener, new PatternTopic(VideoManagerConstants.VM_MSG_STREAM_PUSH_CLOSE_REQUESTED));
      container.addMessageListener(redisPlatformStartSendRtpListener, new PatternTopic(VideoManagerConstants.START_SEND_PUSH_STREAM));
      container.addMessageListener(redisPlatformWaitPushStreamOnlineListener, new PatternTopic(VideoManagerConstants.VM_MSG_STREAM_PUSH_REQUESTED));
      container.addMessageListener(redisPlatformPushStreamOnlineLister, new PatternTopic(VideoManagerConstants.PUSH_STREAM_ONLINE));
        return container;
    }
}