Compare commits

..
3 Commits
Author SHA1 Message Date
wonder bde3725684 ♻️Refactor: 整理包结构 2025-10-15 11:52:55 +08:00
wonder 0f2c656e31 🔄Update: 添加主启动类 2025-10-15 11:44:06 +08:00
wonder cbd8f91a55 🔧Chore: 修改消息类和配置文件属性 2025-10-15 11:43:15 +08:00
6 changed files with 18 additions and 5 deletions
@@ -0,0 +1,11 @@
package cn.hezhaohui.rabbitmq;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
@@ -1,4 +1,4 @@
package cn.hezhaohui.rabbitmq; package cn.hezhaohui.rabbitmq.amqp;
import org.springframework.amqp.core.Message; import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.amqp.rabbit.annotation.RabbitListener;
@@ -1,5 +1,6 @@
package cn.hezhaohui.rabbitmq; package cn.hezhaohui.rabbitmq.amqp;
import cn.hezhaohui.rabbitmq.entity.Message;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import lombok.Data; import lombok.Data;
import org.springframework.amqp.core.AmqpTemplate; import org.springframework.amqp.core.AmqpTemplate;
@@ -1,4 +1,4 @@
package cn.hezhaohui.rabbitmq; package cn.hezhaohui.rabbitmq.entity;
import lombok.Data; import lombok.Data;
@@ -7,5 +7,5 @@ import lombok.Data;
*/ */
@Data @Data
public class Message { public class Message {
private String content; final private String content;
} }
+1 -1
View File
@@ -7,5 +7,5 @@ spring:
host: localhost host: localhost
port: 5672 port: 5672
username: wonder username: wonder
password: Dn293830 password: dn293830
virtual-host: /template virtual-host: /template
@@ -1,5 +1,6 @@
package cn.hezhaohui.rabbitmq; package cn.hezhaohui.rabbitmq;
import cn.hezhaohui.rabbitmq.amqp.MessageProducer;
import jakarta.annotation.Resource; import jakarta.annotation.Resource;
import org.junit.jupiter.api.Test; import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest; import org.springframework.boot.test.context.SpringBootTest;