Channel stacking is prevented during message sending with Message Pro…

…ducer.
byerlikaya · Jun 14, 2024 · f5c8b4e · f5c8b4e
1 parent 8cbacf5
commit f5c8b4e
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 8 deletions.
diff --git a/src/Basic.RabbitMQ/Basic.RabbitMQ.csproj b/src/Basic.RabbitMQ/Basic.RabbitMQ.csproj
@@ -5,15 +5,15 @@
     <Title>Basic.RabbitMQ</Title>
     <Authors>Barış Yerlikaya</Authors>
     <Company>Barış Yerlikaya</Company>
-    <Copyright>Copyright (c) 2023 Barış Yerlikaya</Copyright>
+    <Copyright>Copyright (c) 2024 Barış Yerlikaya</Copyright>
     <PackageProjectUrl>https://github.com/byerlikaya/Basic.RabbitMQ</PackageProjectUrl>
     <PackageReadmeFile>README.md</PackageReadmeFile>
     <RepositoryUrl>https://github.com/byerlikaya/Basic.RabbitMQ</RepositoryUrl>
     <PackageTags>RabbitMQ rabbitmq</PackageTags>
     <PackageLicenseFile>LICENSE</PackageLicenseFile>
     <Description>.NET Core library that simplifies RabbitMQ usage and works with the Direct Exchange type.</Description>
     <PackageId>Basic.RabbitMQ</PackageId>
-    <Version>1.1.0.1</Version>
+    <Version>1.1.1</Version>
     <Product>Basic.RabbitMQ</Product>
     <LangVersion>preview</LangVersion>
   </PropertyGroup>

diff --git a/src/Basic.RabbitMQ/MessageProducer.cs b/src/Basic.RabbitMQ/MessageProducer.cs
@@ -4,8 +4,7 @@ public class MessageProducer(RabbitMQClientService rabbitMqClientService) : IMes
 {
     public void SendMessage(string queueName, string routingKey, string message)
     {
-        var channel = rabbitMqClientService.Connect(queueName);
-
+        using var channel = rabbitMqClientService.Connect(queueName);
         channel.QueueBind(
             exchange: rabbitMqClientService.BrokerOptions.ExchangeName,
             queue: queueName,
@@ -26,8 +25,7 @@ public void SendMessage(string queueName, string routingKey, string message)
 
     public void SendMessage<T>(string queueName, string routingKey, T message)
     {
-        var channel = rabbitMqClientService.Connect(queueName);
-
+        using var channel = rabbitMqClientService.Connect(queueName);
         channel.QueueBind(
             exchange: rabbitMqClientService.BrokerOptions.ExchangeName,
             queue: queueName,

diff --git a/src/Basic.RabbitMQ/Services/RabbitMQClientService.cs b/src/Basic.RabbitMQ/Services/RabbitMQClientService.cs
@@ -1,7 +1,7 @@
 namespace Basic.RabbitMQ.Services;
 
-public class RabbitMQClientService(IConfiguration configuration, ConnectionFactory connectionFactory)
-    : IDisposable
+// ReSharper disable once InconsistentNaming
+public class RabbitMQClientService(IConfiguration configuration, ConnectionFactory connectionFactory) : IDisposable
 {
     public readonly MessageBrokerOptions BrokerOptions = configuration.GetSection(nameof(MessageBrokerOptions)).Get<MessageBrokerOptions>();