From ddb1b8f95ed506fadb83029741130ebaf3d3accd Mon Sep 17 00:00:00 2001 From: zhouxiunai <154707516@qq.com> Date: Mon, 18 Mar 2019 18:30:52 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E5=A4=9A=E4=BD=99=E7=9A=84?= =?UTF-8?q?=E6=89=93=E5=8D=B0=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gzzn/omms/msgexchangeapi/scheduled/FltrSendScheduled.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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()); }