code cleanup

Vick-Chow · Mar 19, 2024 · 5af24b0 · 5af24b0
1 parent 8c3b21d
commit 5af24b0
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 33 deletions.
diff --git a/...t/bifromq-mqtt-server/src/main/java/com/baidu/bifromq/mqtt/AbstractMQTTBrokerBuilder.java b/...t/bifromq-mqtt-server/src/main/java/com/baidu/bifromq/mqtt/AbstractMQTTBrokerBuilder.java
@@ -36,7 +36,6 @@ abstract class AbstractMQTTBrokerBuilder<T extends AbstractMQTTBrokerBuilder<T>>
     long writeLimit = 512 * 1024;
     long readLimit = 512 * 1024;
     int maxBytesInMessage = 256 * 1024;
-    private int maxResendTimes = 5;
     int mqttBossELGThreads;
     int mqttWorkerELGThreads;
     IAuthProvider authProvider;
@@ -129,13 +128,8 @@ public T maxBytesInMessage(int maxBytesInMessage) {
         return thisT();
     }
 
-    public T maxResendTimes(int maxResendTimes) {
-        this.maxResendTimes = maxResendTimes;
-        return thisT();
-    }
-
-    public T mqttBossELGThreads(int mqttWorkerELGThreads) {
-        this.mqttBossELGThreads = mqttWorkerELGThreads;
+    public T mqttBossELGThreads(int mqttBossELGThreads) {
+        this.mqttBossELGThreads = mqttBossELGThreads;
         return thisT();
     }
 

diff --git a/bifromq-mqtt/bifromq-mqtt-server/src/main/java/com/baidu/bifromq/mqtt/utils/SubUtil.java b/bifromq-mqtt/bifromq-mqtt-server/src/main/java/com/baidu/bifromq/mqtt/utils/SubUtil.java
diff --git a/bifromq-sysprops/src/main/java/com/baidu/bifromq/sysprops/BifroMQSysProp.java b/bifromq-sysprops/src/main/java/com/baidu/bifromq/sysprops/BifroMQSysProp.java
@@ -19,7 +19,6 @@
 import com.baidu.bifromq.sysprops.parser.IntegerParser;
 import com.baidu.bifromq.sysprops.parser.LongParser;
 import com.baidu.bifromq.sysprops.parser.PropParser;
-import java.time.Duration;
 import lombok.extern.slf4j.Slf4j;
 
 @Slf4j