支持用 folkmq:// 地址连接 broker

noear · Dec 5, 2023 · a481c1b · a481c1b
1 parent d02bf64
commit a481c1b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/folkmq-server/src/main/java/org/noear/folkmq/server/pro/mq/FolkmqLifecycleBean.java b/folkmq-server/src/main/java/org/noear/folkmq/server/pro/mq/FolkmqLifecycleBean.java
@@ -88,7 +88,7 @@ private void startBrokerSession(String brokerServers, boolean saveEnable, MqWatc
 
         //同时支持：Broker 和 Multi-Broker
         for (String server : brokerServers.split(",")) {
-            server = server.trim();
+            server = server.trim().replace("folkmq://","sd:tcp://");
 
             if (Utils.isNotEmpty(server)) {
                 Session session = SocketD.createClient(server)