@@ -90,19 +90,4 @@ public class IotMessageListener implements MessageListener { | |||||
log.error("processMessage occurs error ", e); | 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); | |||||
// //} | |||||
// } | |||||
} | } |