diff --git a/src/DotNetCore.CAP.RabbitMQ/CAP.RabbitMQCapOptionsExtension.cs b/src/DotNetCore.CAP.RabbitMQ/CAP.RabbitMQCapOptionsExtension.cs index 6f86746..55b6d37 100644 --- a/src/DotNetCore.CAP.RabbitMQ/CAP.RabbitMQCapOptionsExtension.cs +++ b/src/DotNetCore.CAP.RabbitMQ/CAP.RabbitMQCapOptionsExtension.cs @@ -23,7 +23,7 @@ namespace DotNetCore.CAP services.AddSingleton(); services.Configure(_configure); - services.AddSingleton(); + services.AddSingleton(); services.AddSingleton(); services.AddSingleton(); } diff --git a/src/DotNetCore.CAP.RabbitMQ/IPublishMessageSender.RabbitMQ.cs b/src/DotNetCore.CAP.RabbitMQ/ITransport.RabbitMQ.cs similarity index 93% rename from src/DotNetCore.CAP.RabbitMQ/IPublishMessageSender.RabbitMQ.cs rename to src/DotNetCore.CAP.RabbitMQ/ITransport.RabbitMQ.cs index 2cb7efe..d1f9afb 100644 --- a/src/DotNetCore.CAP.RabbitMQ/IPublishMessageSender.RabbitMQ.cs +++ b/src/DotNetCore.CAP.RabbitMQ/ITransport.RabbitMQ.cs @@ -13,14 +13,14 @@ using RabbitMQ.Client.Framing; namespace DotNetCore.CAP.RabbitMQ { - internal sealed class RabbitMQMessageSender : ITransport + internal sealed class RabbitMQTransport : ITransport { private readonly IConnectionChannelPool _connectionChannelPool; private readonly ILogger _logger; private readonly string _exchange; - public RabbitMQMessageSender( - ILogger logger, + public RabbitMQTransport( + ILogger logger, IConnectionChannelPool connectionChannelPool) { _logger = logger;