From f89c8d19d96fdbff3081ba4ac48ea3e72168bc59 Mon Sep 17 00:00:00 2001
From: liuhaonan <31457034@qq.com>
Date: 星期五, 20 五月 2022 15:52:44 +0800
Subject: [PATCH] 日志
---
ximon-admin/src/main/java/com/sandu/ximon/admin/manager/iot/amqp/InitAmqpListener.java | 19 +++++++++++++------
1 files changed, 13 insertions(+), 6 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 9899d8f..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();
- }*/
+ if (isOpen) {
+ new AmqpClient(
+ mqttMainBoardConfig
+ ).execute();
+ }
+ }
}
--
Gitblit v1.9.3