Mark Mongo time serialized to local instance time by default. #1400

dotnetcore · Sep 11, 2023 · c362bfa · c362bfa
1 parent ff76dea
commit c362bfa
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/src/DotNetCore.CAP.MongoDB/StorageMessage.cs b/src/DotNetCore.CAP.MongoDB/StorageMessage.cs
@@ -20,8 +20,10 @@ internal class ReceivedMessage
 
     public string Content { get; set; } = default!;
 
+    [BsonDateTimeOptions(Kind = DateTimeKind.Local)]
     public DateTime Added { get; set; }
 
+    [BsonDateTimeOptions(Kind = DateTimeKind.Local)]
     public DateTime? ExpiresAt { get; set; }
 
     public int Retries { get; set; }
@@ -39,8 +41,10 @@ internal class PublishedMessage
 
     public string Content { get; set; } = default!;
 
+    [BsonDateTimeOptions(Kind = DateTimeKind.Local)]
     public DateTime Added { get; set; }
 
+    [BsonDateTimeOptions(Kind = DateTimeKind.Local)]
     public DateTime? ExpiresAt { get; set; }
 
     public int Retries { get; set; }
@@ -58,5 +62,6 @@ public class Lock
 
     public string Instance { get; set; } = default!;
 
+    [BsonDateTimeOptions(Kind = DateTimeKind.Local)]
     public DateTime LastLockTime { get; set; }
 }