From 27ce0e352497d4263429d592ec04288dd17a4783 Mon Sep 17 00:00:00 2001
From: Savorboard <yangxiaodong1214@126.com>
Date: Mon, 9 Apr 2018 20:02:58 +0800
Subject: [PATCH] refactor

---
 src/DotNetCore.CAP.Kafka/CAP.KafkaCapOptionsExtension.cs | 2 +-
 src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs    | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/DotNetCore.CAP.Kafka/CAP.KafkaCapOptionsExtension.cs b/src/DotNetCore.CAP.Kafka/CAP.KafkaCapOptionsExtension.cs
index 04493f5..88db8fe 100644
--- a/src/DotNetCore.CAP.Kafka/CAP.KafkaCapOptionsExtension.cs
+++ b/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>();
         }
     }
 }
\ No newline at end of file
diff --git a/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs b/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs
index acbff96..402d0fa 100644
--- a/src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs
+++ b/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();
         }