From ec63fb17c5ba3e5b2a5a4106c25b4e249a2f980f Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期二, 22 十一月 2022 18:44:51 +0800
Subject: [PATCH] changes
---
ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/InitAmqpListener.java | 23 +++++++++++++++--------
1 files changed, 15 insertions(+), 8 deletions(-)
diff --git a/ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/InitAmqpListener.java b/ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/InitAmqpListener.java
index ce8a8ad..51a5ae4 100644
--- a/ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/InitAmqpListener.java
+++ b/ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/InitAmqpListener.java
@@ -1,6 +1,8 @@
package com.sandu.ximon.admin.manager.iot.amqp;
import lombok.AllArgsConstructor;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import javax.annotation.PostConstruct;
@@ -10,15 +12,20 @@
* @date 2021/12/2 17:45
*/
@Component
-@AllArgsConstructor
+//@AllArgsConstructor
public class InitAmqpListener {
- private final MqttMainBoardConfig mqttMainBoardConfig;
+ @Autowired
+ private MqttMainBoardConfig mqttMainBoardConfig;
+ @Value("${listenter.isOpen}")
+ private boolean isOpen;
-// @PostConstruct
-// public void initListener() throws Exception {
-// new AmqpClient(
-// mqttMainBoardConfig
-// ).execute();
-// }
+ @PostConstruct
+ public void initListener() throws Exception {
+ if (isOpen) {
+ new AmqpClient(
+ mqttMainBoardConfig
+ ).execute();
+ }
+ }
}
--
Gitblit v1.9.3