Add basic functions: QueueDelete and QueuePurge.

ifgris · Sep 9, 2024 · 419d681 · 419d681
1 parent a00dad4
commit 419d681
Show file tree

Hide file tree

Showing 2 changed files with 36 additions and 1 deletion.
diff --git a/Src/NanoRabbit/IRabbitHelper.cs b/Src/NanoRabbit/IRabbitHelper.cs
@@ -72,6 +72,18 @@ public interface IRabbitHelper
     /// <param name="arguments"></param>
     public void QueueBind(string queueName, string exchangeName, string routingKey, IDictionary<string, object> arguments);
     /// <summary>
+    /// Delete a queue.
+    /// </summary>
+    /// <param name="queueName"></param>
+    /// <param name="ifUnused"></param>
+    /// <param name="ifEmpty"></param>
+    public void QueueDelete(string queueName, bool ifUnused, bool ifEmpty);
+    /// <summary>
+    /// Purge a queue of messages.
+    /// </summary>
+    /// <param name="queueName"></param>
+    public void QueuePurge(string queueName);
+    /// <summary>
     /// Create a custom BasicProperties.
     /// </summary>
     /// <returns></returns>

diff --git a/Src/NanoRabbit/RabbitHelper.cs b/Src/NanoRabbit/RabbitHelper.cs
@@ -247,6 +247,26 @@ public void QueueBind(string queueName, string exchangeName, string routingKey,
             _channel.QueueBind(queueName, exchangeName, routingKey, arguments);
         }
 
+        /// <summary>
+        /// Delete a queue.
+        /// </summary>
+        /// <param name="queueName"></param>
+        /// <param name="ifUnused"></param>
+        /// <param name="ifEmpty"></param>
+        public void QueueDelete(string queueName, bool ifUnused, bool ifEmpty)
+        {
+            _channel.QueueDelete(queueName, ifUnused, ifEmpty);
+        }
+
+        /// <summary>
+        /// Purge a queue of messages.
+        /// </summary>
+        /// <param name="queueName"></param>
+        public void QueuePurge(string queueName)
+        {
+            _channel.QueuePurge(queueName);
+        }
+
         /// <summary>
         /// Create a custom BasicProperties.
         /// </summary>
@@ -256,6 +276,10 @@ public IBasicProperties CreateBasicProperties()
             return _channel.CreateBasicProperties();
         }
 
+        #endregion
+
+        #region private functions
+
         /// <summary>
         /// Serialize message.
         /// </summary>
@@ -349,7 +373,6 @@ private void AddConsumerInternal(string consumerName, Func<string, Task>? onMess
             }
         }
 
-
         #endregion
 
         public void Dispose()