fix

Geeksltd · Feb 14, 2024 · 177e445 · 177e445
1 parent c6179e2
commit 177e445
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/Olive.Aws.EventBus/EventBusQueue.cs b/Olive.Aws.EventBus/EventBusQueue.cs
@@ -64,9 +64,9 @@ public async Task<string> Publish(string message)
 
             if (IsFifo)
             {
-                var eventBusMessage = JsonConvert.DeserializeObject<EventBusMessage>(message);
-                request.MessageDeduplicationId =eventBusMessage.DeduplicationId.Or(Guid.NewGuid().ToString("N"));
-                request.MessageGroupId = eventBusMessage.MessageGroupId.Or("Default");
+                var eventBusMessage = JsonConvert.DeserializeObject<JObject>(message);
+                request.MessageDeduplicationId = eventBusMessage["DeduplicationId"]?.ToString().Or(Guid.NewGuid().ToString("N"));
+                request.MessageGroupId = eventBusMessage["MessageGroupId"]?.ToString().Or("Default");
             }
 
             try
@@ -102,11 +102,11 @@ public async Task<IEnumerable<string>> PublishBatch(IEnumerable<string> messages
             {
                 request.Entries
                     .ForEach(message =>
-                {
-                    var eventBusMessage = JsonConvert.DeserializeObject<EventBusMessage>(message.MessageBody);
-                    message.MessageDeduplicationId =eventBusMessage.DeduplicationId.Or(Guid.NewGuid().ToString("N"));
-                    message.MessageGroupId = eventBusMessage.MessageGroupId.Or("Default");
-                });
+                    {
+                        var eventBusMessage = JsonConvert.DeserializeObject<JObject>(message.MessageBody);
+                        message.MessageDeduplicationId = eventBusMessage["DeduplicationId"]?.ToString().Or(Guid.NewGuid().ToString("N"));
+                        message.MessageGroupId = eventBusMessage["MessageGroupId"]?.ToString().Or("Default");
+                    });
             }
 
             await Limiter.Add(request.Entries.Count);

diff --git a/Olive.Aws.EventBus/Olive.Aws.EventBus.csproj b/Olive.Aws.EventBus/Olive.Aws.EventBus.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
-    <Version>2.1.156</Version>
+    <Version>2.1.157</Version>
   </PropertyGroup>
 
   <ItemGroup>