From 0525bc16b69d18e4c080a3fdde27cca8f9c6a362 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E5=86=9B?= <510423039@qq.com>
Date: Thu, 13 Jan 2022 12:10:06 +0800
Subject: [PATCH] =?UTF-8?q?=E2=AC=86=EF=B8=8F=20=E5=8D=87=E7=BA=A7Abp5.1.1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 aspnet-core/Directory.Build.props                        | 4 ++--
 .../Lion.AbpPro.CAP/AbpProAbpCapDistributedEventBus.cs   | 9 +++++++--
 2 files changed, 9 insertions(+), 4 deletions(-)

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>();