优化对讲逻辑

648540858

2022-07-03 72c1b36d6d2ece497e032c8434641d6576590f9d

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

@@ -1,7 +1,10 @@
package com.genersoft.iot.vmp.conf;



import com.genersoft.iot.vmp.common.VideoManagerConstants;

import com.genersoft.iot.vmp.service.impl.RedisGPSMsgListener;

import com.genersoft.iot.vmp.service.impl.RedisAlarmMsgListener;

import com.genersoft.iot.vmp.service.impl.RedisGpsMsgListener;

import com.genersoft.iot.vmp.service.impl.RedisGbPlayMsgListener;

import com.genersoft.iot.vmp.service.impl.RedisStreamMsgListener;

import org.apache.commons.lang3.StringUtils;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.beans.factory.annotation.Value;

@@ -46,7 +49,16 @@
   private int poolMaxWait;



   @Autowired

   private RedisGPSMsgListener redisGPSMsgListener;

   private RedisGpsMsgListener redisGPSMsgListener;



   @Autowired

   private RedisAlarmMsgListener redisAlarmMsgListener;



   @Autowired

   private RedisStreamMsgListener redisStreamMsgListener;



   @Autowired

   private RedisGbPlayMsgListener redisGbPlayMsgListener;



   @Bean

   public JedisPool jedisPool() {

@@ -92,7 +104,10 @@


        RedisMessageListenerContainer container = new RedisMessageListenerContainer();

        container.setConnectionFactory(connectionFactory);

      container.addMessageListener(redisGPSMsgListener, new PatternTopic(VideoManagerConstants.WVP_MSG_GPS_PREFIX));

      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));

        return container;

    }