From d3c4e4780bab533337a5261bc09350af51f76740 Mon Sep 17 00:00:00 2001
From: xieb <vip_xiaobin810@163.com>
Date: Thu, 03 Aug 2023 18:12:20 +0800
Subject: [PATCH] 增加接收消息队列信息
---
skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java | 21 +++++++++++++++++++++
1 files changed, 21 insertions(+), 0 deletions(-)
diff --git a/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java
new file mode 100644
index 0000000..e6f12c5
--- /dev/null
+++ b/skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java
@@ -0,0 +1,21 @@
+package cn.gistack.nky.rabbitmq;
+
+import org.springframework.amqp.core.Message;
+import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
+
+/**
+ * @PROJECT_NAME: skjcmanager
+ * @DESCRIPTION: 接收南科院消息队列
+ * @USER: aix
+ * @DATE: 2023/8/3 15:54
+ */
+@Component
+public class MyRabbitReceiver {
+
+ @RabbitListener(queues = "alarm")
+ public void processMessage(Message message) {
+ System.out.println("收到消息"+new String(message.getBody()));
+ }
+
+}
--
Gitblit v1.9.3