From cda9d3a12240ad659efc11603862487d946715b2 Mon Sep 17 00:00:00 2001
From: zhanzhiqin <895896009@qq.com>
Date: 星期三, 27 四月 2022 18:14:08 +0800
Subject: [PATCH] fix
---
ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/InitAmqpListener.java | 21 ++++++++++++++-------
1 files changed, 14 insertions(+), 7 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 ae06b5f..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
+ @PostConstruct
public void initListener() throws Exception {
- new AmqpClient(
- mqttMainBoardConfig
- ).execute();
- }*/
+ if (isOpen) {
+ new AmqpClient(
+ mqttMainBoardConfig
+ ).execute();
+ }
+ }
}
--
Gitblit v1.9.3