Fix: DateTime parsing with InvariantCulture (#1590)

Co-authored-by: Nikoloz.Gobejishvili <Nikoloz.Gobejishvili@SPLP1011>
dotnetcore · Sep 26, 2024 · cd6d0ee · cd6d0ee
1 parent 9b1b112
commit cd6d0ee
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/DotNetCore.CAP/ICapTransaction.Base.cs b/src/DotNetCore.CAP/ICapTransaction.Base.cs
@@ -3,6 +3,7 @@
 
 using System;
 using System.Collections.Concurrent;
+using System.Globalization;
 using System.Threading;
 using System.Threading.Tasks;
 using DotNetCore.CAP.Messages;
@@ -55,7 +56,7 @@ protected virtual void Flush()
                 if (isDelayMessage)
                 {
 
-                    _dispatcher.EnqueueToScheduler(message, DateTime.Parse(message.Origin.Headers[Headers.SentTime]!)).ConfigureAwait(false);
+                    _dispatcher.EnqueueToScheduler(message, DateTime.Parse(message.Origin.Headers[Headers.SentTime]!, CultureInfo.InvariantCulture)).ConfigureAwait(false);
 
                 }
                 else

diff --git a/src/DotNetCore.CAP/Internal/ICapPublisher.Default.cs b/src/DotNetCore.CAP/Internal/ICapPublisher.Default.cs
@@ -4,6 +4,7 @@
 using System;
 using System.Collections.Generic;
 using System.Diagnostics;
+using System.Globalization;
 using System.Threading;
 using System.Threading.Tasks;
 using DotNetCore.CAP.Diagnostics;
@@ -142,11 +143,11 @@ private async Task PublishInternalAsync<T>(string name, T? value, IDictionary<st
         {
             publishTime += delayTime.Value;
             headers.Add(Headers.DelayTime, delayTime.Value.ToString());
-            headers.Add(Headers.SentTime, publishTime.ToString());
+            headers.Add(Headers.SentTime, publishTime.ToString(CultureInfo.InvariantCulture));
         }
         else
         {
-            headers.Add(Headers.SentTime, publishTime.ToString());
+            headers.Add(Headers.SentTime, publishTime.ToString(CultureInfo.InvariantCulture));
         }
 
         var message = new Message(headers, value);