删除多余的打印消息
This commit is contained in:
@@ -34,7 +34,7 @@ public class FltrSendScheduled {
|
|||||||
public void scheduled()
|
public void scheduled()
|
||||||
{
|
{
|
||||||
//
|
//
|
||||||
logger.info("开始发送航班动态信息");
|
//logger.info("开始发送航班动态信息");
|
||||||
|
|
||||||
try {
|
try {
|
||||||
List<FLTR> fltrs = msgBufferService.takeAllFltr();
|
List<FLTR> fltrs = msgBufferService.takeAllFltr();
|
||||||
@@ -44,6 +44,7 @@ public class FltrSendScheduled {
|
|||||||
String schdMsg = JsonUtil.getString(fltrs);
|
String schdMsg = JsonUtil.getString(fltrs);
|
||||||
kafkaservice.msgSend("schd", schdMsg);
|
kafkaservice.msgSend("schd", schdMsg);
|
||||||
}
|
}
|
||||||
|
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
logger.error("动态航班信息发送异常:{}",e.getMessage());
|
logger.error("动态航班信息发送异常:{}",e.getMessage());
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user