搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2022-10-17 1e1364e51a66614469b91e396d33a54bdf8f6e98 
 src/main/java/com/genersoft/iot/vmp/conf/redis/RedisConfig.java


@@ -3,7 +3,7 @@




import com.alibaba.fastjson.parser.ParserConfig;


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


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


import com.genersoft.iot.vmp.service.redisMsg.*;


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


import org.springframework.cache.annotation.CachingConfigurerSupport;


import org.springframework.context.annotation.Bean;


@@ -12,7 +12,6 @@


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.data.redis.listener.PatternTopic;


import org.springframework.data.redis.listener.RedisMessageListenerContainer;


import org.springframework.data.redis.serializer.RedisSerializer;


import org.springframework.data.redis.serializer.StringRedisSerializer;




import com.genersoft.iot.vmp.utils.redis.FastJsonRedisSerializer;


@@ -43,7 +42,10 @@


   private RedisPushStreamStatusMsgListener redisPushStreamStatusMsgListener;




   @Autowired


   private RedisPushStreamListMsgListener redisPushStreamListMsgListener;


   private RedisPushStreamStatusListMsgListener redisPushStreamListMsgListener;




   @Autowired


   private RedisPushStreamResponseListener redisPushStreamResponseListener;




   @Bean


   public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {


@@ -81,7 +83,7 @@


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


        return container;


    }




}