From bde3725684c763c08e7845d0bb9338343913ebc3 Mon Sep 17 00:00:00 2001 From: Wonder Date: Wed, 15 Oct 2025 11:52:55 +0800 Subject: [PATCH] =?UTF-8?q?=20=E2=99=BB=EF=B8=8FRefactor:=20=E6=95=B4?= =?UTF-8?q?=E7=90=86=E5=8C=85=E7=BB=93=E6=9E=84?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/cn/hezhaohui/rabbitmq/{ => amqp}/MessageConsumer.java | 2 +- .../java/cn/hezhaohui/rabbitmq/{ => amqp}/MessageProducer.java | 3 ++- src/main/java/cn/hezhaohui/rabbitmq/{ => entity}/Message.java | 2 +- src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java | 1 + 4 files changed, 5 insertions(+), 3 deletions(-) rename src/main/java/cn/hezhaohui/rabbitmq/{ => amqp}/MessageConsumer.java (93%) rename src/main/java/cn/hezhaohui/rabbitmq/{ => amqp}/MessageProducer.java (86%) rename src/main/java/cn/hezhaohui/rabbitmq/{ => entity}/Message.java (75%) diff --git a/src/main/java/cn/hezhaohui/rabbitmq/MessageConsumer.java b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java similarity index 93% rename from src/main/java/cn/hezhaohui/rabbitmq/MessageConsumer.java rename to src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java index 737ef3e..358d2fc 100644 --- a/src/main/java/cn/hezhaohui/rabbitmq/MessageConsumer.java +++ b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageConsumer.java @@ -1,4 +1,4 @@ -package cn.hezhaohui.rabbitmq; +package cn.hezhaohui.rabbitmq.amqp; import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.annotation.RabbitListener; diff --git a/src/main/java/cn/hezhaohui/rabbitmq/MessageProducer.java b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java similarity index 86% rename from src/main/java/cn/hezhaohui/rabbitmq/MessageProducer.java rename to src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java index a600484..ec21e03 100644 --- a/src/main/java/cn/hezhaohui/rabbitmq/MessageProducer.java +++ b/src/main/java/cn/hezhaohui/rabbitmq/amqp/MessageProducer.java @@ -1,5 +1,6 @@ -package cn.hezhaohui.rabbitmq; +package cn.hezhaohui.rabbitmq.amqp; +import cn.hezhaohui.rabbitmq.entity.Message; import jakarta.annotation.Resource; import lombok.Data; import org.springframework.amqp.core.AmqpTemplate; diff --git a/src/main/java/cn/hezhaohui/rabbitmq/Message.java b/src/main/java/cn/hezhaohui/rabbitmq/entity/Message.java similarity index 75% rename from src/main/java/cn/hezhaohui/rabbitmq/Message.java rename to src/main/java/cn/hezhaohui/rabbitmq/entity/Message.java index 607d4e2..27ee973 100644 --- a/src/main/java/cn/hezhaohui/rabbitmq/Message.java +++ b/src/main/java/cn/hezhaohui/rabbitmq/entity/Message.java @@ -1,4 +1,4 @@ -package cn.hezhaohui.rabbitmq; +package cn.hezhaohui.rabbitmq.entity; import lombok.Data; diff --git a/src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java b/src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java index 173c492..f4b96df 100644 --- a/src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java +++ b/src/test/java/cn/hezhaohui/rabbitmq/RabbitMQTest.java @@ -1,5 +1,6 @@ package cn.hezhaohui.rabbitmq; +import cn.hezhaohui.rabbitmq.amqp.MessageProducer; import jakarta.annotation.Resource; import org.junit.jupiter.api.Test; import org.springframework.boot.test.context.SpringBootTest;