Tweak some processors to visual for overwrite.

src/DotNetCore.CAP.Pulsar/DotNetCore.CAP.Pulsar.csproj

@@ -12,7 +12,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="Pulsar.Client" Version="2.9.1" />
+    <PackageReference Include="Pulsar.Client" Version="2.10.0" />
   </ItemGroup>
 
 </Project>

src/DotNetCore.CAP.Pulsar/PulsarConsumerClient.cs

@@ -7,8 +7,6 @@ using System.Reflection;
 using System.Threading;
 using DotNetCore.CAP.Messages;
 using DotNetCore.CAP.Transport;
-using Microsoft.Extensions.Logging;
-using Microsoft.Extensions.Logging.Abstractions;
 using Microsoft.Extensions.Options;
 using Pulsar.Client.Api;
 using Pulsar.Client.Common;

src/DotNetCore.CAP/Processor/IProcessor.Collector.cs

@@ -32,7 +32,7 @@ namespace DotNetCore.CAP.Processor
             _tableNames = new[] { initializer.GetPublishedTableName(), initializer.GetReceivedTableName() };
         }
 
-        public async Task ProcessAsync(ProcessingContext context)
+        public virtual async Task ProcessAsync(ProcessingContext context)
         {
             foreach (var table in _tableNames)
             {

src/DotNetCore.CAP/Processor/IProcessor.NeedRetry.cs

@@ -33,7 +33,7 @@ namespace DotNetCore.CAP.Processor
             _waitingInterval = TimeSpan.FromSeconds(options.Value.FailedRetryInterval);
         }
 
-        public async Task ProcessAsync(ProcessingContext context)
+        public virtual async Task ProcessAsync(ProcessingContext context)
         {
             if (context == null)
             {

src/DotNetCore.CAP/Processor/IProcessor.TransportCheck.cs

@@ -21,7 +21,7 @@ namespace DotNetCore.CAP.Processor
             _waitingInterval = TimeSpan.FromSeconds(30);
         }
 
-        public async Task ProcessAsync(ProcessingContext context)
+        public virtual async Task ProcessAsync(ProcessingContext context)
         {
             if (context == null)
             {