From 6fed7ec752fd8692285acfa02ba0c1f17c2c74ce Mon Sep 17 00:00:00 2001
From: tk <fiyne1a@dingtalk.com>
Date: Thu, 6 Mar 2025 09:38:31 +0800
Subject: [PATCH] =?UTF-8?q?chore:=20=F0=9F=94=A8=20=E4=BA=8B=E4=BB=B6?=
 =?UTF-8?q?=E5=8F=91=E5=B8=83=E5=99=A8=E6=8E=A5=E5=8F=A3=E9=80=9A=E9=81=93?=
 =?UTF-8?q?=E6=95=B0=E9=87=8F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

[skip ci]
---
 build/code.quality.props                                     | 2 +-
 .../EventBus/DefaultEventPublisher.cs                        | 3 +++
 .../NetAdmin.Infrastructure/EventBus/IEventPublisher.cs      | 5 +++++
 3 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/build/code.quality.props b/build/code.quality.props
index 3850bd3f..1475dfcf 100644
--- a/build/code.quality.props
+++ b/build/code.quality.props
@@ -23,7 +23,7 @@
             <PrivateAssets>all</PrivateAssets>
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>
-        <PackageReference Include="SonarAnalyzer.CSharp" Version="10.6.0.109712">
+        <PackageReference Include="SonarAnalyzer.CSharp" Version="10.7.0.110445">
             <PrivateAssets>all</PrivateAssets>
             <IncludeAssets>runtime; build; native; contentfiles; analyzers; buildtransitive</IncludeAssets>
         </PackageReference>
diff --git a/src/backend/NetAdmin/NetAdmin.Infrastructure/EventBus/DefaultEventPublisher.cs b/src/backend/NetAdmin/NetAdmin.Infrastructure/EventBus/DefaultEventPublisher.cs
index 510840dc..c206f416 100644
--- a/src/backend/NetAdmin/NetAdmin.Infrastructure/EventBus/DefaultEventPublisher.cs
+++ b/src/backend/NetAdmin/NetAdmin.Infrastructure/EventBus/DefaultEventPublisher.cs
@@ -28,6 +28,9 @@ public sealed class DefaultEventPublisher : IEventPublisher
             }, App.EffectiveTypes.Where(x => typeof(IEventSubscriber).IsAssignableFrom(x) && x.IsClass && !x.IsAbstract).SelectMany(x => x.GetMethods(BindingFlags.Instance | BindingFlags.Public).Where(y => y.IsDefined(typeof(EventSubscribeAttribute)))).ToList());
     }
 
+    /// <inheritdoc />
+    public int ChannelCount => _eventChannel.Reader.Count;
+
     /// <inheritdoc />
     public async Task PublishAsync<T>(IEventData<T> eventData)
     {
diff --git a/src/backend/NetAdmin/NetAdmin.Infrastructure/EventBus/IEventPublisher.cs b/src/backend/NetAdmin/NetAdmin.Infrastructure/EventBus/IEventPublisher.cs
index f1bbf0c7..0be2bc15 100644
--- a/src/backend/NetAdmin/NetAdmin.Infrastructure/EventBus/IEventPublisher.cs
+++ b/src/backend/NetAdmin/NetAdmin.Infrastructure/EventBus/IEventPublisher.cs
@@ -5,6 +5,11 @@ namespace NetAdmin.Infrastructure.EventBus;
 /// </summary>
 public interface IEventPublisher
 {
+    /// <summary>
+    ///     通道数量
+    /// </summary>
+    int ChannelCount { get; }
+
     /// <summary>
     ///     发布一条消息
     /// </summary>