add IPublishExecutor

src/DotNetCore.CAP.Kafka/CAP.KafkaCapOptionsExtension.cs

@@ -24,6 +24,7 @@ namespace DotNetCore.CAP
 
             services.AddSingleton<IConsumerClientFactory, KafkaConsumerClientFactory>();
             services.AddSingleton<IQueueExecutor, PublishQueueExecutor>();
+            services.AddSingleton<IPublishExecutor, PublishQueueExecutor>();
         }
     }
 }

src/DotNetCore.CAP.RabbitMQ/CAP.RabbitMQCapOptionsExtension.cs

@@ -23,10 +23,9 @@ namespace DotNetCore.CAP
             services.AddSingleton(options);
 
             services.AddSingleton<IConsumerClientFactory, RabbitMQConsumerClientFactory>();
-
             services.AddSingleton<ConnectionPool>();
-
             services.AddSingleton<IQueueExecutor, PublishQueueExecutor>();
+            services.AddSingleton<IPublishExecutor, PublishQueueExecutor>();
         }
     }
 }