| | |
|---|
| | | @Autowired |
|---|
| | | private RedisRpcConfig redisRpcConfig; |
|---|
| | | |
|---|
| | | @Autowired |
|---|
| | | private RedisPushStreamResponseListener redisPushStreamCloseResponseListener; |
|---|
| | | |
|---|
| | | |
|---|
| | | /** |
|---|
| | | * redis消息监听器容器 可以添加多个监听不同话题的redis监听器，只需要把消息监听器和相应的消息订阅处理器绑定，该消息监听器 |
|---|
| | |
|---|
| | | container.addMessageListener(redisPushStreamListMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_PUSH_STREAM_LIST_CHANGE)); |
|---|
| | | container.addMessageListener(redisCloseStreamMsgListener, new PatternTopic(VideoManagerConstants.VM_MSG_STREAM_PUSH_CLOSE)); |
|---|
| | | container.addMessageListener(redisRpcConfig, new PatternTopic(RedisRpcConfig.REDIS_REQUEST_CHANNEL_KEY)); |
|---|
| | | container.addMessageListener(redisPushStreamCloseResponseListener, new PatternTopic(VideoManagerConstants.VM_MSG_STREAM_PUSH_RESPONSE)); |
|---|
| | | return container; |
|---|
| | | } |
|---|
| | | } |
|---|
