add event loadbalancing

2024-07-27 01:33:17 +08:00
parent 1ee8d941e9
commit 683cf9176a
2 changed files with 12 additions and 1 deletions
@@ -53,7 +53,12 @@ public partial class Synapse
        };
        foreach (var ev in EventRegistry)
        {
-            var topic = $"$queue/{esTopicPrefix}{ev.Key}";
+            
+            var topic = $"{esTopicPrefix}{ev.Key}";
+            if (Options.EventLoadBalancing)
+            {
+                topic = "$queue/" + topic;
+            }
            var evSubOpts = MqttFactory.CreateSubscribeOptionsBuilder()
                .WithTopicFilter(o => o.WithTopic(topic)).Build();
            Client.SubscribeAsync(evSubOpts).Wait();