move proxy config

streamnative · Oct 22, 2024 · 43b785b · 43b785b
1 parent 82c3ca7
commit 43b785b
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/...er/src/main/java/io/streamnative/pulsar/handlers/mqtt/broker/MQTTServerConfiguration.java b/...er/src/main/java/io/streamnative/pulsar/handlers/mqtt/broker/MQTTServerConfiguration.java
@@ -25,12 +25,6 @@
 @Setter
 public class MQTTServerConfiguration extends MQTTCommonConfiguration {
 
-    @FieldContext(
-            category = CATEGORY_MQTT,
-            required = true,
-            doc = "Listener for the MQTT Server."
-    )
-    private String mqttListeners = "mqtt://127.0.0.1:1883";
 
     @FieldContext(
             category = CATEGORY_MQTT,

diff --git a/...on/src/main/java/io/streamnative/pulsar/handlers/mqtt/common/MQTTCommonConfiguration.java b/...on/src/main/java/io/streamnative/pulsar/handlers/mqtt/common/MQTTCommonConfiguration.java
@@ -46,6 +46,13 @@ public class MQTTCommonConfiguration extends ServiceConfiguration {
     @Category
     public static final String CATEGORY_WS = "MQTT over WebSocket";
 
+    @FieldContext(
+            category = CATEGORY_MQTT,
+            required = true,
+            doc = "Listener for the MQTT Server."
+    )
+    private String mqttListeners = "mqtt://127.0.0.1:1883";
+
     @FieldContext(
             category = CATEGORY_MQTT,
             required = false,