优化国标级联心跳与注册时长
parent
0858f7995b
commit
1654683da7
|
@ -4,7 +4,6 @@ package com.genersoft.iot.vmp.conf.redis;
|
||||||
import com.genersoft.iot.vmp.common.VideoManagerConstants;
|
import com.genersoft.iot.vmp.common.VideoManagerConstants;
|
||||||
import com.genersoft.iot.vmp.service.redisMsg.*;
|
import com.genersoft.iot.vmp.service.redisMsg.*;
|
||||||
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Autowired;
|
||||||
import org.springframework.cache.annotation.CachingConfigurerSupport;
|
|
||||||
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Bean;
|
||||||
import org.springframework.context.annotation.Configuration;
|
import org.springframework.context.annotation.Configuration;
|
||||||
import org.springframework.core.annotation.Order;
|
import org.springframework.core.annotation.Order;
|
||||||
|
@ -21,7 +20,7 @@ import org.springframework.data.redis.listener.RedisMessageListenerContainer;
|
||||||
*/
|
*/
|
||||||
@Configuration
|
@Configuration
|
||||||
@Order(value=1)
|
@Order(value=1)
|
||||||
public class RedisConfig extends CachingConfigurerSupport {
|
public class RedisMsgListenConfig {
|
||||||
|
|
||||||
@Autowired
|
@Autowired
|
||||||
private RedisGpsMsgListener redisGPSMsgListener;
|
private RedisGpsMsgListener redisGPSMsgListener;
|
||||||
|
@ -45,8 +44,6 @@ public class RedisConfig extends CachingConfigurerSupport {
|
||||||
private RedisPushStreamResponseListener redisPushStreamResponseListener;
|
private RedisPushStreamResponseListener redisPushStreamResponseListener;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* redis消息监听器容器 可以添加多个监听不同话题的redis监听器,只需要把消息监听器和相应的消息订阅处理器绑定,该消息监听器
|
* redis消息监听器容器 可以添加多个监听不同话题的redis监听器,只需要把消息监听器和相应的消息订阅处理器绑定,该消息监听器
|
||||||
* 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理
|
* 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理
|
|
@ -137,7 +137,7 @@ public class PlatformServiceImpl implements IPlatformService {
|
||||||
()-> {
|
()-> {
|
||||||
registerTask(parentPlatform);
|
registerTask(parentPlatform);
|
||||||
},
|
},
|
||||||
(parentPlatform.getExpires() - 10) *1000);
|
parentPlatform.getExpires() *1000);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -183,7 +183,7 @@ public class PlatformServiceImpl implements IPlatformService {
|
||||||
logger.error("[命令发送失败] 国标级联 发送心跳: {}", e.getMessage());
|
logger.error("[命令发送失败] 国标级联 发送心跳: {}", e.getMessage());
|
||||||
}
|
}
|
||||||
},
|
},
|
||||||
(parentPlatform.getKeepTimeout() - 10)*1000);
|
parentPlatform.getKeepTimeout()*1000);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue