diff --git a/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FltrSendScheduled.java b/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FltrSendScheduled.java index d8f230bc..69d8cffd 100644 --- a/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FltrSendScheduled.java +++ b/src/main/java/com/gzzn/omms/msgexchangeapi/scheduled/FltrSendScheduled.java @@ -34,7 +34,7 @@ public class FltrSendScheduled { public void scheduled() { // - logger.info("开始发送航班动态信息"); + //logger.info("开始发送航班动态信息"); try { List fltrs = msgBufferService.takeAllFltr(); @@ -44,6 +44,7 @@ public class FltrSendScheduled { String schdMsg = JsonUtil.getString(fltrs); kafkaservice.msgSend("schd", schdMsg); } + } catch (Exception e) { logger.error("动态航班信息发送异常:{}",e.getMessage()); }