refactor: txMsg 默认关闭重试和清理

Author: cadecode

common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/config/TxMsgProperties.java

@@ -43,7 +43,7 @@ public class TxMsgProperties implements InitializingBean {
     /**
      * 是否开启重试
      */
-    private Boolean enableRetry = true;
+    private Boolean enableRetry = false;
 
     /**
      * 定时重试间隔时间
@@ -58,7 +58,7 @@ public class TxMsgProperties implements InitializingBean {
     /**
      * 是否开启自动清理
      */
-    private Boolean autoClear = true;
+    private Boolean autoClear = false;
 
     /**
      * 自动清理多久之前的记录

…oot/common/plugin/mq/task/TxMsgTask.java …mmon/plugin/mq/job/TxMsgJobRegister.javacommon/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/task/TxMsgTask.java renamed to common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/job/TxMsgJobRegister.java common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/task/TxMsgTask.java renamed to common/plugin/mq/src/main/java/com/github/cadecode/uniboot/common/plugin/mq/job/TxMsgJobRegister.java

@@ -1,4 +1,4 @@
-package com.github.cadecode.uniboot.common.plugin.mq.task;
+package com.github.cadecode.uniboot.common.plugin.mq.job;
 
 import cn.hutool.core.util.ObjUtil;
 import com.github.cadecode.uniboot.common.plugin.mq.config.TxMsgProperties;
@@ -19,7 +19,7 @@
 @Slf4j
 @RequiredArgsConstructor
 @Component
-public class TxMsgTask {
+public class TxMsgJobRegister {
 
     private final ThreadPoolTaskScheduler taskScheduler;
 
@@ -29,13 +29,14 @@ public class TxMsgTask {
 
     @EventListener(ApplicationStartedEvent.class)
     public void onApplicationStartedEvent() {
-        if (ObjUtil.equals(txMsgProperties.getEnableRetry(), false)) {
-            log.info("TxMsg task enable retry false");
-            return;
+        // 消息定时 retry
+        log.info("TxMsg task do retry start, {}", txMsgProperties.getEnableRetry());
+        if (ObjUtil.equals(txMsgProperties.getEnableRetry(), true)) {
+            taskScheduler.scheduleWithFixedDelay(txMsgTaskHandler::doRetry, txMsgProperties.getRetryFixDelay());
         }
-        log.info("TxMsg task do retry started");
-        taskScheduler.scheduleWithFixedDelay(txMsgTaskHandler::doRetry, txMsgProperties.getRetryFixDelay());
-        log.info("TxMsg task do clear started, {}", txMsgProperties.getAutoClear());
+
+        // 消息定时清理
+        log.info("TxMsg task do clear start, {}", txMsgProperties.getAutoClear());
         if (ObjUtil.equal(txMsgProperties.getAutoClear(), true)) {
             taskScheduler.scheduleWithFixedDelay(() -> txMsgTaskHandler.doClear(txMsgProperties.getAutoClearInterval()),
                     txMsgProperties.getClearFixDelay());