feat: 对 TxMsg retry 和 auto clear 实现提供 xxl-job 支持

Author: cadecode

framework/framework_base/pom.xml

@@ -59,6 +59,10 @@
             <groupId>com.github.cadecode</groupId>
             <artifactId>uni-boot-common-plugin-storage</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.github.cadecode</groupId>
+            <artifactId>uni-boot-common-plugin-job</artifactId>
+        </dependency>
         <dependency>
             <groupId>com.github.cadecode</groupId>
             <artifactId>uni-boot-framework-api</artifactId>

framework/framework_base/src/main/java/com/github/cadecode/uniboot/framework/base/plugin/handler/MqTxMsgHandler.java

@@ -20,6 +20,7 @@
 import com.github.cadecode.uniboot.framework.base.plugin.convert.PlgMqMsgConvert;
 import com.github.cadecode.uniboot.framework.base.plugin.enums.SendStateEnum;
 import com.github.cadecode.uniboot.framework.base.plugin.service.PlgMqMsgService;
+import com.xxl.job.core.handler.annotation.XxlJob;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.amqp.core.Message;
@@ -64,6 +65,7 @@ public class MqTxMsgHandler extends AbstractTxMsgHandler {
 
     private final PlgMqMsgService mqMsgService;
 
+    @XxlJob("MqTxMsgRetry")
     @Override
     public void doRetry() {
         String lockKey = KeyGeneUtil.lockKey(LOCK_TX_MSG_DO_RETRY);
@@ -110,6 +112,7 @@ private boolean updateRetryTime(String txMsgId, int newLeftRetryTimes, Date newN
                 .update(new PlgMqMsg());
     }
 
+    @XxlJob("MqTxMsgAutoClear")
     @Override
     public void doClear(Long autoClearInterval) {
         String lockKey = KeyGeneUtil.lockKey(LOCK_TX_MSG_DO_CLEAR);