修复更新推流状态sql错误

648540858

2022-07-19 28b5cc39d0a2d9939f70b4c980a31d9b27fc1e4c

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

@@ -1,7 +1,7 @@
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.*;

import org.apache.commons.lang3.StringUtils;

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

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

@@ -46,7 +46,19 @@
   private int poolMaxWait;



   @Autowired

   private RedisGPSMsgListener redisGPSMsgListener;

   private RedisGpsMsgListener redisGPSMsgListener;



   @Autowired

   private RedisAlarmMsgListener redisAlarmMsgListener;



   @Autowired

   private RedisStreamMsgListener redisStreamMsgListener;



   @Autowired

   private RedisGbPlayMsgListener redisGbPlayMsgListener;



   @Autowired

   private RedisPushStreamStatusMsgListener redisPushStreamStatusMsgListener;



   @Bean

   public JedisPool jedisPool() {

@@ -93,6 +105,10 @@
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();

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

        return container;

    }