diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java index 2c594f31..1398edd6 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/runner/SchdWaitRunner.java @@ -8,6 +8,7 @@ import java.util.concurrent.TimeUnit; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import org.springframework.core.env.Environment; import com.gzzn.omms.msgexchangeapi.entity.Cminmsg; import com.gzzn.omms.msgexchangeapi.redis.RedisKeyConstant; @@ -28,8 +29,13 @@ public class SchdWaitRunner implements Runnable { private ICminmsgService cminmsgService; private IFlightInfoService flightInfoService; + private Long intervalSeconds; + public SchdWaitRunner() { + Environment env = (Environment)SpringUtil.getBean("environment"); + intervalSeconds = Long.valueOf(env.getProperty("msgExchange.intervalSeconds")); + flightInfoService = (IFlightInfoService) SpringUtil.getBean("flightInfoService"); redisService = (RedisService) SpringUtil.getBean("redisService"); cminmsgService = (ICminmsgService) SpringUtil.getBean("cminmsgService"); @@ -37,9 +43,9 @@ public class SchdWaitRunner implements Runnable { @Override public void run() { - logger.info("获取日计划航班信息返回结果开始..."); + logger.info("获取日计划航班信息返回结果开始...,采集间隔{}",intervalSeconds); Boolean isRun = true; - Long intervalMs = 3000L; + Long intervalMs = 30L; Long tryTimes = 0L; while (isRun) { @@ -75,7 +81,7 @@ public class SchdWaitRunner implements Runnable { //启动消息采集线程 ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(1); - scheduledExecutorService.scheduleAtFixedRate(new MsgExchangeRunner(), 0, 30 , TimeUnit.SECONDS); + scheduledExecutorService.scheduleAtFixedRate(new MsgExchangeRunner(), 0, intervalSeconds , TimeUnit.SECONDS); isRun = false; //退出 diff --git a/src/main/resources/application-dev.yml b/src/main/resources/application-dev.yml index 633fbd75..d78b0945 100644 --- a/src/main/resources/application-dev.yml +++ b/src/main/resources/application-dev.yml @@ -51,4 +51,6 @@ kafka: concurrency: 10 group: id: test +msgExchange: + intervalSeconds: 30 \ No newline at end of file