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 @@ all runtime; build; native; contentfiles; analyzers; buildtransitive - + all runtime; build; native; contentfiles; analyzers; buildtransitive 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()); } + /// + public int ChannelCount => _eventChannel.Reader.Count; + /// public async Task PublishAsync(IEventData 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; /// public interface IEventPublisher { + /// + /// 通道数量 + /// + int ChannelCount { get; } + /// /// 发布一条消息 ///