diff --git a/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java b/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java index 663e9d5..976f7e2 100644 --- a/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java +++ b/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java @@ -43,7 +43,7 @@ public class IotMessageListener implements MessageListener { // 第二个参数为首次执行的延时时间,第三个参数为定时执行的间隔时间 // 10:秒 5:秒 // 第一次执行的时间为10秒,然后每隔五秒执行一次 - service.scheduleAtFixedRate(runnable, 120, 60, TimeUnit.SECONDS); + service.scheduleAtFixedRate(runnable, 30, 60, TimeUnit.SECONDS); } private ExecutorService executorService;