- DeferredMessageProcessorResetInterval

Shuttle · Sep 11, 2022 · 74438fc · 74438fc
1 parent 612651c
commit 74438fc
Show file tree

Hide file tree

Showing 3 changed files with 11 additions and 8 deletions.
diff --git a/Shuttle.Esb.Tests/Options/InboxOptionsFixture.cs b/Shuttle.Esb.Tests/Options/InboxOptionsFixture.cs
@@ -25,6 +25,8 @@ public void Should_be_able_to_load_a_full_configuration()
 
             Assert.AreEqual(TimeSpan.FromMinutes(30), options.Inbox.DurationToIgnoreOnFailure[0]);
             Assert.AreEqual(TimeSpan.FromHours(1), options.Inbox.DurationToIgnoreOnFailure[1]);
+
+            Assert.AreEqual(TimeSpan.FromMinutes(5), options.Inbox.DeferredMessageProcessorResetInterval);
         }
     }
 }
diff --git a/Shuttle.Esb.Tests/Options/appsettings.json b/Shuttle.Esb.Tests/Options/appsettings.json
@@ -18,7 +18,8 @@
           "00:30:00",
           "01:00:00"
         ],
-        "MaximumFailureCount": 25
+        "MaximumFailureCount": 25,
+        "DeferredMessageProcessorResetInterval": "00:05:00" 
       },
       "Outbox": {
         "WorkQueueUri": "queue://./outbox-work",

diff --git a/Shuttle.Esb.Tests/TranportMessageFixture.cs b/Shuttle.Esb.Tests/TranportMessageFixture.cs
@@ -58,7 +58,7 @@ public void Should_be_able_to_register_failures_and_have_IgnoreTillDate_set()
         {
             var message = new TransportMessage();
 
-            var before = DateTime.Now;
+            var before = DateTime.UtcNow;
 
             message.RegisterFailure("failure");
 
@@ -74,25 +74,25 @@ public void Should_be_able_to_register_failures_and_have_IgnoreTillDate_set()
                     TimeSpan.FromHours(2)
                 };
 
-            Assert.IsFalse(DateTime.Now.AddMinutes(3) <= message.IgnoreTillDate);
+            Assert.IsFalse(DateTime.UtcNow.AddMinutes(3) <= message.IgnoreTillDate);
 
             message.RegisterFailure("failure", durationToIgnoreOnFailure[0]);
 
-            var ignoreTillDate = DateTime.Now.AddMinutes(3);
+            var ignoreTillDate = DateTime.UtcNow.AddMinutes(3);
 
             Assert.IsTrue(ignoreTillDate.AddMilliseconds(-100) < message.IgnoreTillDate && ignoreTillDate.AddMilliseconds(100) > message.IgnoreTillDate);
-            Assert.IsFalse(DateTime.Now.AddMinutes(30) < message.IgnoreTillDate);
+            Assert.IsFalse(DateTime.UtcNow.AddMinutes(30) < message.IgnoreTillDate);
 
             message.RegisterFailure("failure", durationToIgnoreOnFailure[1]);
 
-            ignoreTillDate = DateTime.Now.AddMinutes(30);
+            ignoreTillDate = DateTime.UtcNow.AddMinutes(30);
 
             Assert.IsTrue(ignoreTillDate.AddMilliseconds(-100) < message.IgnoreTillDate && ignoreTillDate.AddMilliseconds(100) > message.IgnoreTillDate);
-            Assert.IsFalse(DateTime.Now.AddHours(2) < message.IgnoreTillDate);
+            Assert.IsFalse(DateTime.UtcNow.AddHours(2) < message.IgnoreTillDate);
 
             message.RegisterFailure("failure", durationToIgnoreOnFailure[2]);
 
-            ignoreTillDate = DateTime.Now.AddHours(2);
+            ignoreTillDate = DateTime.UtcNow.AddHours(2);
 
             Assert.IsTrue(ignoreTillDate.AddMilliseconds(-100) < message.IgnoreTillDate && ignoreTillDate.AddMilliseconds(100) > message.IgnoreTillDate);
         }