refactor: update AckQueueOptions

WeihanLi · Jan 4, 2025 · e074b86 · e074b86
1 parent ba14da8
commit e074b86
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/WeihanLi.Common/Event/AckQueue.cs b/src/WeihanLi.Common/Event/AckQueue.cs
@@ -8,9 +8,9 @@ public sealed class AckQueueOptions
 {
     public TimeSpan AckTimeout { get; set; } = TimeSpan.FromMinutes(1);
 
-    public bool AutoRequeue { get; set; }
+    public bool AutoRequeue { get; set; } = true;
 
-    public TimeSpan Requeue { get; set; }
+    public TimeSpan Requeue { get; set; } = TimeSpan.FromMinutes(1);
 }
 
 public sealed class AckQueue : DisposableBase

diff --git a/test/WeihanLi.Common.Test/EventsTest/AckQueueTest.cs b/test/WeihanLi.Common.Test/EventsTest/AckQueueTest.cs
@@ -5,7 +5,10 @@ namespace WeihanLi.Common.Test.EventsTest
 {
     public class AckQueueTest
     {
-        private readonly AckQueue _ackQueue = new();
+        private readonly AckQueue _ackQueue = new(new()
+        {
+            AutoRequeue = false
+        });
 
         [Fact]
         public async Task EnqueueAsync_ShouldAddMessageToQueue()