From 6d3fa2a2114baa52445a7dc92359e39c7ce5a5f7 Mon Sep 17 00:00:00 2001 From: luozukai Date: Mon, 16 Sep 2019 11:03:52 +0800 Subject: [PATCH] =?UTF-8?q?[=E4=BF=AE=E6=94=B9][=E7=BB=93=E7=AE=97?= =?UTF-8?q?=E5=8D=95][=E4=BC=98=E5=8C=96=E5=A4=87=E6=B3=A8=E5=B1=95?= =?UTF-8?q?=E7=A4=BA]?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/test/java/com/iformall/service/test/Test.java | 4 ---- .../main/java/com/iformall/schedule/MsgReSendSchedule.java | 6 ++++-- 2 files changed, 4 insertions(+), 6 deletions(-) diff --git a/mallinkAdmin/src/test/java/com/iformall/service/test/Test.java b/mallinkAdmin/src/test/java/com/iformall/service/test/Test.java index afc13dcdd..396ebac38 100644 --- a/mallinkAdmin/src/test/java/com/iformall/service/test/Test.java +++ b/mallinkAdmin/src/test/java/com/iformall/service/test/Test.java @@ -69,10 +69,6 @@ public class Test { @Autowired MqBaseProducer mqBaseProducer; -// @Autowired -// MsgReSendSchedu - - @Autowired private WxBillSettleService wxBillSettleService; @Autowired diff --git a/mallinkSchedule/src/main/java/com/iformall/schedule/MsgReSendSchedule.java b/mallinkSchedule/src/main/java/com/iformall/schedule/MsgReSendSchedule.java index 73cad0f16..d9f968677 100644 --- a/mallinkSchedule/src/main/java/com/iformall/schedule/MsgReSendSchedule.java +++ b/mallinkSchedule/src/main/java/com/iformall/schedule/MsgReSendSchedule.java @@ -24,9 +24,10 @@ public class MsgReSendSchedule { @Autowired private MqBaseProducer mqBaseProducer; - //@Scheduled(cron = "0 */5 * * * *?") // 每5分钟检查一次 + //@Scheduled(cron = "0 */1 * * * *?") // 每5分钟检查一次 @Scheduled(cron = "*/10 * * * * ?") // 测试10秒中一次 public void msgReSend() { + logger.info("消息重发开始..."); //消息重发 WxMsgRecord msgRecord = new WxMsgRecord(); msgRecord.setMsgStatus(EnumMsgRecordStatus.SEND_FAIL.getCode()); @@ -67,10 +68,11 @@ public class MsgReSendSchedule { mqBaseProducer.sendMessage(msg, EnumMsgMqTopic.DEFAULT.getCode(), EnumMsgMqTag.DEFAULT.getCode(), EnumMsgMqKey.DEFAULT.getCode()); } } catch (Exception e) { + e.printStackTrace(); logger.error("消息重发错误:" + e.getMessage()); } } - + logger.info("消息重发结束..."); }