refactor.

src/DotNetCore.CAP.Kafka/KafkaConsumerClient.cs

@@ -3,7 +3,6 @@ using System.Text;
 using System.Threading;
 using Confluent.Kafka;
 using Confluent.Kafka.Serialization;
-using DotNetCore.CAP.Infrastructure;
 
 namespace DotNetCore.CAP.Kafka
 {

src/DotNetCore.CAP.RabbitMQ/RabbitMQConsumerClient.cs

@@ -2,7 +2,6 @@
 using System.Text;
 using System.Threading;
 using System.Threading.Tasks;
-using DotNetCore.CAP.Infrastructure;
 using RabbitMQ.Client;
 using RabbitMQ.Client.Events;
 

src/DotNetCore.CAP/QueueExecutorFactory.cs

 using System;
 using System.Linq;
-using System.Reflection;
 using DotNetCore.CAP.Models;
 using Microsoft.Extensions.DependencyInjection;