Merge pull request #5 from byerlikaya/disposable

IDisposable

README.md

@@ -68,6 +68,6 @@ Task BasicConsumerReceived(object sender, BasicDeliverEventArgs @event)
 
     channel?.BasicAck(@event.DeliveryTag, false);
 
-    return Task.CompletedTask;
+    await Task.Yield();
 }
 ```

src/Basic.RabbitMQ/Basic.RabbitMQ.csproj

@@ -13,7 +13,7 @@
     <PackageLicenseFile>LICENSE</PackageLicenseFile>
     <Description>.NET Core library that simplifies RabbitMQ usage and works with the Direct Exchange type.</Description>
     <PackageId>Basic.RabbitMQ</PackageId>
-    <Version>2.0.0.1</Version>
+    <Version>2.0.0.2</Version>
     <Product>Basic.RabbitMQ</Product>
     <LangVersion>preview</LangVersion>
   </PropertyGroup>

src/Basic.RabbitMQ/Interfaces/IMessageConsumer.cs

@@ -1,8 +1,7 @@
 namespace Basic.RabbitMQ.Interfaces;
 
-public interface IMessageConsumer
+public interface IMessageConsumer : IDisposable
 {
     IModel Channel(string queueName, string routingKey, ushort prefetchCount = 1);
-
     AsyncEventingBasicConsumer GetConsumer(IModel channel);
 }

src/Basic.RabbitMQ/Interfaces/IMessageProducer.cs

@@ -1,6 +1,6 @@
 namespace Basic.RabbitMQ.Interfaces;
 
-public interface IMessageProducer
+public interface IMessageProducer : IDisposable
 {
     void SendMessage(string queueName, string routingKey, string message);
     void SendMessage<T>(string queueName, string routingKey, T message);

src/Basic.RabbitMQ/MessageConsumer.cs

@@ -2,7 +2,7 @@
 
 public class MessageConsumer(
     RabbitMqClientService rabbitMqClientService,
-    ConnectionFactory connectionFactory) : IMessageConsumer, IDisposable
+    ConnectionFactory connectionFactory) : IMessageConsumer
 {
     private IConnection _connection;
 

src/Basic.RabbitMQ/MessageProducer.cs

@@ -1,7 +1,7 @@
 namespace Basic.RabbitMQ;
 
 public class MessageProducer(RabbitMqClientService rabbitMqClientService, ConnectionFactory connectionFactory)
-    : IMessageProducer, IDisposable
+    : IMessageProducer
 {
     private readonly IConnection _connection = connectionFactory.CreateConnection();