From 50bc6ee76ffcebc0b539e0fb5698a3911e5f6c02 Mon Sep 17 00:00:00 2001
From: zhongrj <646384940@qq.com>
Date: Mon, 07 Aug 2023 10:31:03 +0800
Subject: [PATCH] Merge branch 'jtdev' of https://hbsl-code.gistack.cn/hbwri/manager into jtdev
---
skjcmanager/skjcmanager-service/skjcmanager-nky/src/main/java/cn/gistack/nky/rabbitmq/MyRabbitReceiver.java | 12 +++++++++++-
1 files changed, 11 insertions(+), 1 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
index e6f12c5..3883f7b 100644
--- 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
@@ -1,5 +1,9 @@
package cn.gistack.nky.rabbitmq;
+import cn.gistack.nky.entity.AlarmGet;
+import cn.gistack.nky.service.IAlarmGetService;
+import com.alibaba.fastjson.JSONObject;
+import lombok.AllArgsConstructor;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@@ -11,11 +15,17 @@
* @DATE: 2023/8/3 15:54
*/
@Component
+@AllArgsConstructor
public class MyRabbitReceiver {
+ private final IAlarmGetService alarmGetService;
@RabbitListener(queues = "alarm")
public void processMessage(Message message) {
- System.out.println("收到消息"+new String(message.getBody()));
+
+// AlarmGet alarmGet = JSONObject.parseObject(new String(message.getBody()), AlarmGet.class);
+// alarmGetService.save(alarmGet);
+//
+// System.out.println("收到消息"+new String(message.getBody()));
}
}
--
Gitblit v1.9.3