fix(ackmode): Correção para permitir o reject requeue false

src/Liquid.Messaging.RabbitMq/Liquid.Messaging.RabbitMq.csproj

@@ -9,7 +9,7 @@
     <Copyright>Avanade 2019</Copyright>
     <PackageProjectUrl>https://github.com/Avanade/Liquid.Messaging</PackageProjectUrl>
     <PackageIcon>logo.png</PackageIcon>
-    <Version>6.0.0-preview-20231130-01</Version>
+    <Version>6.0.0-preview-20231130-02</Version>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <Description>
       The Liquid.Messaging.RabbitMq provides producer and consumer patterns to allow the send and consumption of Messaging inside your microservice.

src/Liquid.Messaging.RabbitMq/RabbitMqConsumer.cs

@@ -83,7 +83,21 @@ protected async Task MessageHandler(BasicDeliverEventArgs deliverEvent, Cancella
             {
                 if (!_autoAck)
                 {
-                    _channelModel.BasicNack(deliverEvent.DeliveryTag, false, true);
+                    var queueAckMode = _settings.AdvancedSettings.QueueAckModeSettings ?? new QueueAckModeSettings() { QueueAckMode = QueueAckModeEnum.BasicAck, Requeue = true };
+
+                    switch (queueAckMode.QueueAckMode)
+                    {
+                        case QueueAckModeEnum.BasicAck:
+                            _channelModel.BasicNack(deliverEvent.DeliveryTag, false, queueAckMode.Requeue);
+                            break;
+                        case QueueAckModeEnum.BasicReject:
+                            _channelModel.BasicReject(deliverEvent.DeliveryTag, queueAckMode.Requeue);
+                            break;
+                        default:
+                            _channelModel.BasicNack(deliverEvent.DeliveryTag, false, true);
+                            break;
+                    }
+
                 }
             }
         }

src/Liquid.Messaging.RabbitMq/Settings/AdvancedSettings.cs

@@ -80,5 +80,10 @@ public class AdvancedSettings
         /// The queue arguments.
         /// </value>
         public IDictionary<string, object> QueueArguments { get; set; }
+
+        /// <summary>
+        /// Queue Ack Mode Settings
+        /// </summary>
+        public QueueAckModeSettings QueueAckModeSettings { get; set; }
     }
 }

src/Liquid.Messaging.RabbitMq/Settings/QueueAckModeEnum.cs

@@ -0,0 +1,25 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Liquid.Messaging.RabbitMq.Settings
+{
+    /// <summary>
+    /// Defines the AckMode
+    /// </summary>
+    public enum QueueAckModeEnum
+    {
+        /// <summary>
+        /// Basic Ack
+        /// </summary>
+        BasicAck = 0,
+
+        /// <summary>
+        /// Reject Ack
+        /// </summary>
+        BasicReject = 1
+
+    }
+}

src/Liquid.Messaging.RabbitMq/Settings/QueueAckModeSettings.cs

@@ -0,0 +1,32 @@
+using System;
+using System.Collections.Generic;
+using System.Diagnostics.CodeAnalysis;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Liquid.Messaging.RabbitMq.Settings
+{
+
+    /// <summary>
+    /// Queue Ack Mode Settings
+    /// </summary>
+    [ExcludeFromCodeCoverage]
+    public class QueueAckModeSettings
+    {
+
+        /// <summary>
+        /// Gets or sets a value indicating whether the message should requeued.
+        /// </summary>
+        /// <value>
+        ///   <c>true</c> if [requeue]; otherwise, <c>false</c>.
+        /// </value>
+        public bool Requeue { get; set; }
+
+        /// <summary>
+        /// Defines the AckMode
+        /// </summary>
+        public QueueAckModeEnum QueueAckMode { get; set; }
+
+    }
+}