From 2b44f6eaa167e48d14efab11f9b18b8dde7b2460 Mon Sep 17 00:00:00 2001
From: Savorboard <yangxiaodong1214@126.com>
Date: Wed, 29 Sep 2021 16:15:59 +0800
Subject: [PATCH] Upgrade plusar client to 2.8.1

---
 samples/Sample.RabbitMQ.MySql/Sample.RabbitMQ.MySql.csproj | 2 +-
 src/DotNetCore.CAP.Pulsar/DotNetCore.CAP.Pulsar.csproj     | 2 +-
 src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs    | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/samples/Sample.RabbitMQ.MySql/Sample.RabbitMQ.MySql.csproj b/samples/Sample.RabbitMQ.MySql/Sample.RabbitMQ.MySql.csproj
index 7326bf6..a18e14d 100644
--- a/samples/Sample.RabbitMQ.MySql/Sample.RabbitMQ.MySql.csproj
+++ b/samples/Sample.RabbitMQ.MySql/Sample.RabbitMQ.MySql.csproj
@@ -11,7 +11,7 @@
   <ItemGroup>
     <ProjectReference Include="..\..\src\DotNetCore.CAP.Dashboard\DotNetCore.CAP.Dashboard.csproj" />
     <ProjectReference Include="..\..\src\DotNetCore.CAP.MySql\DotNetCore.CAP.MySql.csproj" />
-    <ProjectReference Include="..\..\src\DotNetCore.CAP.RabbitMQ\DotNetCore.CAP.RabbitMQ.csproj" />
+    <ProjectReference Include="..\..\src\DotNetCore.CAP.Pulsar\DotNetCore.CAP.Pulsar.csproj" />
     <ProjectReference Include="..\..\src\DotNetCore.CAP\DotNetCore.CAP.csproj" />
   </ItemGroup>
 
diff --git a/src/DotNetCore.CAP.Pulsar/DotNetCore.CAP.Pulsar.csproj b/src/DotNetCore.CAP.Pulsar/DotNetCore.CAP.Pulsar.csproj
index 8a30f6a..eae8731 100644
--- a/src/DotNetCore.CAP.Pulsar/DotNetCore.CAP.Pulsar.csproj
+++ b/src/DotNetCore.CAP.Pulsar/DotNetCore.CAP.Pulsar.csproj
@@ -17,7 +17,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Pulsar.Client" Version="1.4.3" />
+    <PackageReference Include="Pulsar.Client" Version="2.8.1" />
   </ItemGroup>
 
 </Project>
diff --git a/src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs b/src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs
index 4352a51..e0c55f1 100644
--- a/src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs
+++ b/src/DotNetCore.CAP.Pulsar/IConnectionFactory.Default.cs
@@ -59,7 +59,7 @@ namespace DotNetCore.CAP.Pulsar
                         builder.TlsProtocols(_options.TlsOptions.TlsProtocols);
                     }
 
-                    _client = builder.Build();
+                    _client = builder.BuildAsync().Result;
                 }
 
                 return _client;