From 551ae90155a3d0ab7f624fde7b5e9e6d6f16565b Mon Sep 17 00:00:00 2001 From: dashixiong Date: Sun, 29 Jun 2025 21:21:37 +0800 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=20lombok?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- ems-framework/pom.xml | 5 -- .../config/properties/MqttProperties.java | 57 ++++++++++++++++++- 2 files changed, 55 insertions(+), 7 deletions(-) diff --git a/ems-framework/pom.xml b/ems-framework/pom.xml index 06a1274..809fa4f 100644 --- a/ems-framework/pom.xml +++ b/ems-framework/pom.xml @@ -61,11 +61,6 @@ com.xzzn ems-system - - org.projectlombok - lombok - provided - diff --git a/ems-framework/src/main/java/com/xzzn/framework/config/properties/MqttProperties.java b/ems-framework/src/main/java/com/xzzn/framework/config/properties/MqttProperties.java index f751596..41bb162 100644 --- a/ems-framework/src/main/java/com/xzzn/framework/config/properties/MqttProperties.java +++ b/ems-framework/src/main/java/com/xzzn/framework/config/properties/MqttProperties.java @@ -1,10 +1,8 @@ package com.xzzn.framework.config.properties; -import lombok.Data; import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Configuration; -@Data @Configuration public class MqttProperties { @Value("${mqtt.broker.url}") @@ -28,4 +26,59 @@ public class MqttProperties { @Value("${mqtt.automatic-reconnect:true}") private boolean automaticReconnect; + public String getBrokerUrl() { + return brokerUrl; + } + + public void setBrokerUrl(String brokerUrl) { + this.brokerUrl = brokerUrl; + } + + public String getClientId() { + return clientId; + } + + public void setClientId(String clientId) { + this.clientId = clientId; + } + + public String getUsername() { + return username; + } + + public void setUsername(String username) { + this.username = username; + } + + public String getPassword() { + return password; + } + + public void setPassword(String password) { + this.password = password; + } + + public int getConnectionTimeout() { + return connectionTimeout; + } + + public void setConnectionTimeout(int connectionTimeout) { + this.connectionTimeout = connectionTimeout; + } + + public int getKeepAliveInterval() { + return keepAliveInterval; + } + + public void setKeepAliveInterval(int keepAliveInterval) { + this.keepAliveInterval = keepAliveInterval; + } + + public boolean isAutomaticReconnect() { + return automaticReconnect; + } + + public void setAutomaticReconnect(boolean automaticReconnect) { + this.automaticReconnect = automaticReconnect; + } }