简化队列事件总线

Author: nnhy

NewLife.Core/Caching/MemoryCache.cs

@@ -448,7 +448,7 @@ public override ICollection<T> GetSet<T>(String key)
     public override IEventBus<T> GetEventBus<T>(String topic, String clientId = "")
     {
         var key = $"eventbus:{topic}";
-        var item = GetOrAddItem(key, k => new QueueEventBus<T>(this, topic, clientId));
+        var item = GetOrAddItem(key, k => new QueueEventBus<T>(this, topic));
         return item.Visit<IEventBus<T>>() ??
             throw new InvalidCastException($"Unable to convert the value of [{topic}] from {item.TypeCode} to {typeof(IEventBus<T>)}");
     }

NewLife.Core/Caching/QueueEventBus.cs

@@ -5,21 +5,11 @@
 namespace NewLife.Caching;
 
 /// <summary>消息队列事件总线。通过消息队列来发布和订阅消息</summary>
-public class QueueEventBus<TEvent> : EventBus<TEvent>
+/// <remarks>实例化消息队列事件总线</remarks>
+public class QueueEventBus<TEvent>(ICache cache, String topic) : EventBus<TEvent>
 {
     private IProducerConsumer<TEvent>? _queue;
-    private readonly ICache _cache;
-    private readonly String _topic;
-    private readonly String _clientId;
-    CancellationTokenSource? _source;
-
-    /// <summary>实例化消息队列事件总线</summary>
-    public QueueEventBus(ICache cache, String topic, String clientId)
-    {
-        _cache = cache;
-        _topic = topic;
-        _clientId = clientId;
-    }
+    private CancellationTokenSource? _source;
 
     /// <summary>销毁</summary>
     /// <param name="disposing"></param>
@@ -36,7 +26,7 @@ protected virtual void Init()
     {
         if (_queue != null) return;
 
-        _queue = _cache.GetQueue<TEvent>(_topic);
+        _queue = cache.GetQueue<TEvent>(topic);
     }
 
     /// <summary>发布消息到消息队列</summary>