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("消息重发结束..."); }