Add basic exchange functions.

velviagris · Sep 25, 2024 · 9a7f966 · 9a7f966
1 parent 83a41f6
commit 9a7f966
Show file tree

Hide file tree

Showing 2 changed files with 37 additions and 0 deletions.
diff --git a/Src/NanoRabbit/IRabbitHelper.cs b/Src/NanoRabbit/IRabbitHelper.cs
@@ -1,4 +1,5 @@
 using RabbitMQ.Client;
+using System.Threading.Channels;
 
 namespace NanoRabbit;
 
@@ -70,6 +71,20 @@ public interface IRabbitHelper
     /// <param name="arguments"></param>
     public void ExchangeDeclare(string exchangeName, string exchangeType, bool durable = false, bool autoDelete = false, IDictionary<string, object>? arguments = null);
     /// <summary>
+    /// Bind an exchange to an exchange.
+    /// </summary>
+    /// <param name="exchangeName"></param>
+    /// <param name="source"></param>
+    /// <param name="routingKey"></param>
+    /// <param name="arguments"></param>
+    public void ExchangeBind(string destination, string source, string routingKey, IDictionary<string, object> arguments);
+    /// <summary>
+    /// Delete an exchange.
+    /// </summary>
+    /// <param name="exchangeName"></param>
+    /// <param name="ifUnused"></param>
+    public void ExchangeDelete(string exchangeName, bool ifUnused);
+    /// <summary>
     /// Declare a queue.
     /// </summary>
     /// <param name="queueName"></param>

diff --git a/Src/NanoRabbit/RabbitHelper.cs b/Src/NanoRabbit/RabbitHelper.cs
@@ -297,6 +297,28 @@ public void ExchangeDeclare(string exchangeName, string exchangeType, bool durab
             _channel.ExchangeDeclare(exchangeName, exchangeType, durable, autoDelete, arguments);
         }
 
+        /// <summary>
+        /// Bind an exchange to an exchange.
+        /// </summary>
+        /// <param name="exchangeName"></param>
+        /// <param name="source"></param>
+        /// <param name="routingKey"></param>
+        /// <param name="arguments"></param>
+        public void ExchangeBind(string destination, string source, string routingKey, IDictionary<string, object> arguments)
+        {
+            _channel.ExchangeBind(destination, source, routingKey, arguments);
+        }
+
+        /// <summary>
+        /// Delete an exchange.
+        /// </summary>
+        /// <param name="exchangeName"></param>
+        /// <param name="ifUnused"></param>
+        public void ExchangeDelete(string exchangeName, bool ifUnused)
+        {
+            _channel.ExchangeDelete(exchangeName, ifUnused);
+        }
+
         /// <summary>
         /// Declare a queue based on RabbitMQ.Client.
         /// </summary>