diff --git a/IRaCIS.Core.Infra.EFCore/Interceptor/DispatchDomainEventsInterceptor.cs b/IRaCIS.Core.Infra.EFCore/Interceptor/DispatchDomainEventsInterceptor.cs index 7ed87a5ef..c2daa786a 100644 --- a/IRaCIS.Core.Infra.EFCore/Interceptor/DispatchDomainEventsInterceptor.cs +++ b/IRaCIS.Core.Infra.EFCore/Interceptor/DispatchDomainEventsInterceptor.cs @@ -64,8 +64,12 @@ namespace IRaCIS.Core.Infra.EFCore.Interceptor //延迟调度的消息,比如1h后再消费 await _scheduler.SchedulePublish(DateTime.Now.AddSeconds((int)domainEvent.DelaySeconds!), (object)domainEvent); } + else + { + await _publishEndpoint.Publish(domainEvent.GetType(), domainEvent); + + } - await _publishEndpoint.Publish(domainEvent.GetType(), domainEvent); } }