fix(laboratory): 修改实验室RocketMQ包路径

修改实验室RocketMQ包路径

laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/BaseConsumer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.consumer;
+package com.youlai.laboratory.rocketmq.consumer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/BatchConsumer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.consumer;
+package com.youlai.laboratory.rocketmq.consumer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ExConsumer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.consumer;
+package com.youlai.laboratory.rocketmq.consumer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.common.message.MessageExt;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ReplyConsumer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.consumer;
+package com.youlai.laboratory.rocketmq.consumer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/SQLConsumer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.consumer;
+package com.youlai.laboratory.rocketmq.consumer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ScheduleConsumer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.consumer;
+package com.youlai.laboratory.rocketmq.consumer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/TagConsumer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.consumer;
+package com.youlai.laboratory.rocketmq.consumer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/TestConsumer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.consumer;
+package com.youlai.laboratory.rocketmq.consumer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/controller/TestController.java

@@ -1,8 +1,10 @@
-package com.youlai.lab.rocketmq.controller;
+package com.youlai.laboratory.rocketmq.controller;
 
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
-import com.youlai.lab.rocketmq.producer.*;
-import com.youlai.lab.rocketmq.producer.tx.TxProducer;
+
+
+import com.youlai.laboratory.rocketmq.producer.*;
+import com.youlai.laboratory.rocketmq.producer.tx.TxProducer;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -16,9 +18,9 @@ import javax.annotation.Resource;
  * @date 2022-10-27 01:01
  */
 
-@Api(tags = "测试接口")
+@Api(tags = "[实验室]RocketMQ接口")
 @RestController
-@RequestMapping("test")
+@RequestMapping("rocket")
 public class TestController {
 
     /**

laboratory/src/main/java/com/youlai/laboratory/rocketmq/ext/TxRocketMQTemplate.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.ext;
+package com.youlai.laboratory.rocketmq.ext;
 
 import org.apache.rocketmq.spring.annotation.ExtRocketMQTemplateConfiguration;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/BaseProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.producer.SendCallback;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/BatchProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 /**
  * @author zc

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ExProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/MessageSplitter.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import org.springframework.messaging.Message;
 

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/OrderProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ReplyProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/SQLProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ScheduledProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/TagProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/TestProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer;
+package com.youlai.laboratory.rocketmq.producer;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/tx/TxProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer.tx;
+package com.youlai.laboratory.rocketmq.producer.tx;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;

laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/tx/TxProducerListener.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq.producer.tx;
+package com.youlai.laboratory.rocketmq.producer.tx;
 
 import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.spring.annotation.RocketMQTransactionListener;

laboratory/src/test/java/com/youlai/laboratory/rocketmq/TestProducer.java

@@ -1,4 +1,4 @@
-package com.youlai.lab.rocketmq;
+package com.youlai.laboratory.rocketmq;
 
 import org.apache.rocketmq.common.message.Message;
 import org.springframework.messaging.support.MessageBuilder;