diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/BaseConsumer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/BaseConsumer.java index 932650a71..22a57933e 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/BaseConsumer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/BatchConsumer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/BatchConsumer.java index 7500ed219..37c5483e9 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/BatchConsumer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ExConsumer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ExConsumer.java index 158eb715b..c16249fd7 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ExConsumer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ReplyConsumer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ReplyConsumer.java index 3cd497ac4..4a7da2c20 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ReplyConsumer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/SQLConsumer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/SQLConsumer.java index 4ee1a9ba3..12c6fb6ad 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/SQLConsumer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ScheduleConsumer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ScheduleConsumer.java index a00b0abe1..7b5e82b54 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/ScheduleConsumer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/TagConsumer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/TagConsumer.java index 003c88c36..60ab31d77 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/TagConsumer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/TestConsumer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/TestConsumer.java index 434db88fe..febd69b85 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/consumer/TestConsumer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/controller/TestController.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/controller/TestController.java index 42b0cac4e..00f9aa50e 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/controller/TestController.java +++ b/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 { /** diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/ext/TxRocketMQTemplate.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/ext/TxRocketMQTemplate.java index 2b2c8b484..76f54b035 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/ext/TxRocketMQTemplate.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/BaseProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/BaseProducer.java index b385eed13..8801be7d3 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/BaseProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/BatchProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/BatchProducer.java index 4d016c756..e7cf4b9f1 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/BatchProducer.java +++ b/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 diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ExProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ExProducer.java index a261a75a0..9c7be90ec 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ExProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/MessageSplitter.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/MessageSplitter.java index 153c6e68f..d3fba8814 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/MessageSplitter.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/OrderProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/OrderProducer.java index c8d1de98b..7ffb94832 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/OrderProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ReplyProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ReplyProducer.java index 6bcfcb6c5..10e7367fa 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ReplyProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/SQLProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/SQLProducer.java index 2669a9bd2..da298969e 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/SQLProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ScheduledProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ScheduledProducer.java index 3e2d1feb2..3c61b79f1 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/ScheduledProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/TagProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/TagProducer.java index 33cbf439b..d90b2847a 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/TagProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/TestProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/TestProducer.java index a290464a7..8ed68af79 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/TestProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/tx/TxProducer.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/tx/TxProducer.java index ee1b040e6..c3303318b 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/tx/TxProducer.java +++ b/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; diff --git a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/tx/TxProducerListener.java b/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/tx/TxProducerListener.java index b6f9c9c33..63efc960d 100644 --- a/laboratory/src/main/java/com/youlai/laboratory/rocketmq/producer/tx/TxProducerListener.java +++ b/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; diff --git a/laboratory/src/test/java/com/youlai/laboratory/rocketmq/TestProducer.java b/laboratory/src/test/java/com/youlai/laboratory/rocketmq/TestProducer.java index 66e4de2eb..81d895f9c 100644 --- a/laboratory/src/test/java/com/youlai/laboratory/rocketmq/TestProducer.java +++ b/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;