refactor

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

@@ -28,7 +28,7 @@ namespace DotNetCore.CAP
             services.AddSingleton<IConsumerClientFactory, KafkaConsumerClientFactory>();
             services.AddSingleton<IPublishExecutor, KafkaPublishMessageSender>();
             services.AddSingleton<IPublishMessageSender, KafkaPublishMessageSender>();
-            services.AddSingleton<ConnectionPool>();
+            services.AddSingleton<IConnectionPool,ConnectionPool>();
         }
     }
 }

src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs

@@ -28,7 +28,7 @@ namespace DotNetCore.CAP.RabbitMQ
             _queueName = queueName;
             _connectionChannelPool = connectionChannelPool;
             _rabbitMQOptions = options;
-            _exchageName = options.TopicExchangeName;
+            _exchageName = options.ExchangeName;
 
             InitClient();
         }