diff --git a/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java b/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java index de29acc..87c066a 100644 --- a/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java +++ b/src/main/java/com/telpo/iotgateway/listener/IotMessageListener.java @@ -90,19 +90,4 @@ public class IotMessageListener implements MessageListener { log.error("processMessage occurs error ", e); } } - - - -// @Scheduled(cron = "${scheduler.task.cron}") -// public void countMessages() { -// //log.info("开始执行定时推送失败的推送记录!"); -// // 获取推送失败的记录 -// //try { -// log.warn("约1分钟处理 {} 个请求",count); -// count.getAndSet(0); -// //} catch (Exception e) { -// // log.error("执行定时计数发生异常:", e); -// //} -// } - }