648540858
2024-04-24 c21d973977a9f1d00d26179de764687ddd0ec56c
src/main/java/com/genersoft/iot/vmp/conf/redis/RedisMsgListenConfig.java
@@ -34,23 +34,16 @@
   @Autowired
   private RedisPushStreamStatusListMsgListener redisPushStreamListMsgListener;
   @Autowired
   private RedisPushStreamResponseListener redisPushStreamResponseListener;
   @Autowired
   private RedisCloseStreamMsgListener redisCloseStreamMsgListener;
   @Autowired
   private RedisPushStreamCloseResponseListener redisPushStreamCloseResponseListener;
   @Autowired
   private RedisPlatformWaitPushStreamOnlineListener redisPlatformWaitPushStreamOnlineListener;
   private RedisRpcConfig redisRpcConfig;
   @Autowired
   private RedisPlatformStartSendRtpListener redisPlatformStartSendRtpListener;
   @Autowired
   private RedisPlatformPushStreamOnlineLister redisPlatformPushStreamOnlineLister;
   private RedisPushStreamResponseListener redisPushStreamCloseResponseListener;
   /**
@@ -69,12 +62,9 @@
      container.addMessageListener(redisAlarmMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_SUBSCRIBE_ALARM_RECEIVE));
      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));
      container.addMessageListener(redisRpcConfig, new PatternTopic(RedisRpcConfig.REDIS_REQUEST_CHANNEL_KEY));
      container.addMessageListener(redisPushStreamCloseResponseListener, new PatternTopic(VideoManagerConstants.VM_MSG_STREAM_PUSH_RESPONSE));
        return container;
    }
}