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