feat: 添加发送事务消息测试接口

Author: cadecode

example/example_svc/src/main/java/com/github/cadecode/uniboot/example/svc/controller/MqExampleController.java

@@ -1,12 +1,15 @@
 package com.github.cadecode.uniboot.example.svc.controller;
 
+import com.github.cadecode.uniboot.common.plugin.mq.model.TxMsg;
 import com.github.cadecode.uniboot.common.plugin.mq.util.RabbitUtil;
+import com.github.cadecode.uniboot.common.plugin.mq.util.TxMsgKit;
 import com.github.cadecode.uniboot.example.svc.bean.data.ExampleMsgDo;
 import com.github.cadecode.uniboot.framework.base.annotation.ApiFormat;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.transaction.annotation.Transactional;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
@@ -26,6 +29,8 @@
 @RequestMapping("demo/mq")
 public class MqExampleController {
 
+    private final TxMsgKit txMsgKit;
+
     @ApiOperation("发送 delay 消息")
     @GetMapping("send_delay")
     public boolean sendDelay(@RequestParam String exchange, @RequestParam String routingKey, @RequestParam Integer ms) {
@@ -47,5 +52,19 @@ public boolean sendObj(@RequestParam String exchange, @RequestParam String routi
         RabbitUtil.send(exchange, routingKey, msgDo);
         return true;
     }
+
+    @Transactional(rollbackFor = Exception.class)
+    @ApiOperation("发送事务消息")
+    @GetMapping("send_tx")
+    public boolean sendTx(@RequestParam String exchange, @RequestParam String routingKey) {
+        txMsgKit.sendTx(TxMsg.builder()
+                .bizType("Test biz")
+                .bizKey("TestBiz001")
+                .exchange(exchange)
+                .routingKey(routingKey)
+                .message("Test TxMsg")
+                .build());
+        return true;
+    }
 }