diff --git a/aspnet-core/Directory.Build.props b/aspnet-core/Directory.Build.props
index fdefe3be..34471841 100644
--- a/aspnet-core/Directory.Build.props
+++ b/aspnet-core/Directory.Build.props
@@ -1,8 +1,8 @@
 <Project>
 
 	<PropertyGroup>
-		<AbpPackageVersion>5.0.1</AbpPackageVersion>
-		<DotNetCoreCAPVersion>6.0.0-preview-153999281</DotNetCoreCAPVersion>
+		<AbpPackageVersion>5.1.1</AbpPackageVersion>
+		<DotNetCoreCAPVersion>6.0.0</DotNetCoreCAPVersion>
 		<MicrosoftVersion>6.0.0</MicrosoftVersion>
 		<SystemComponentModelAnnotationsVersion>6.0.0-preview.4.21253.7</SystemComponentModelAnnotationsVersion>
 		<MicrosoftExtensionsDependencyModelVersion>6.0.0</MicrosoftExtensionsDependencyModelVersion>
diff --git a/aspnet-core/frameworks/CAP/src/Lion.AbpPro.CAP/AbpProAbpCapDistributedEventBus.cs b/aspnet-core/frameworks/CAP/src/Lion.AbpPro.CAP/AbpProAbpCapDistributedEventBus.cs
index 4235d173..598063fe 100644
--- a/aspnet-core/frameworks/CAP/src/Lion.AbpPro.CAP/AbpProAbpCapDistributedEventBus.cs
+++ b/aspnet-core/frameworks/CAP/src/Lion.AbpPro.CAP/AbpProAbpCapDistributedEventBus.cs
@@ -29,14 +29,19 @@ namespace Lion.AbpPro.CAP
 
         private readonly UnitOfWorkManager _unitOfWorkManager;
         
+        private IEventHandlerInvoker EventHandlerInvoker { get; }
+        
         public AbpProAbpCapDistributedEventBus(IServiceScopeFactory serviceScopeFactory,
             IOptions<AbpDistributedEventBusOptions> distributedEventBusOptions,
             ICapPublisher capPublisher,
-            ICurrentTenant currentTenant, UnitOfWorkManager unitOfWorkManager)
-            : base(serviceScopeFactory, currentTenant,unitOfWorkManager)
+            ICurrentTenant currentTenant,
+            UnitOfWorkManager unitOfWorkManager,
+            IEventHandlerInvoker eventHandlerInvoker)
+            : base(serviceScopeFactory, currentTenant,unitOfWorkManager,eventHandlerInvoker)
         {
             CapPublisher = capPublisher;
             _unitOfWorkManager = unitOfWorkManager;
+            EventHandlerInvoker = eventHandlerInvoker;
             AbpDistributedEventBusOptions = distributedEventBusOptions.Value;
             HandlerFactories = new ConcurrentDictionary<Type, List<IEventHandlerFactory>>();
             EventTypes = new ConcurrentDictionary<string, Type>();