fix

Geeksltd · Feb 13, 2024 · 84a7bee · 84a7bee
1 parent 9ebaa83
commit 84a7bee
Show file tree

Hide file tree

Showing 8 changed files with 6 additions and 9 deletions.
diff --git a/Olive.Aws.EventBus/EventBusQueue.cs b/Olive.Aws.EventBus/EventBusQueue.cs
@@ -64,7 +64,7 @@ public async Task<string> Publish(string message)
 
             if (IsFifo)
             {
-                var eventBusMessage = JsonConvert.DeserializeObject<IEventBusMessage>(message);
+                var eventBusMessage = JsonConvert.DeserializeObject<EventBusMessage>(message);
                 request.MessageDeduplicationId =eventBusMessage.DeduplicationId.Or(Guid.NewGuid().ToString("N"));
                 request.MessageGroupId = eventBusMessage.MessageGroupId.Or("Default");
             }
@@ -103,7 +103,7 @@ public async Task<IEnumerable<string>> PublishBatch(IEnumerable<string> messages
                 request.Entries
                     .ForEach(message =>
                 {
-                    var eventBusMessage = JsonConvert.DeserializeObject<IEventBusMessage>(message.MessageBody);
+                    var eventBusMessage = JsonConvert.DeserializeObject<EventBusMessage>(message.MessageBody);
                     message.MessageDeduplicationId =eventBusMessage.DeduplicationId.Or(Guid.NewGuid().ToString("N"));
                     message.MessageGroupId = eventBusMessage.MessageGroupId.Or("Default");
                 });

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.155</Version>
+    <Version>2.1.156</Version>
   </PropertyGroup>
 
   <ItemGroup>

diff --git a/Olive.Entities.Data.EF.Replication/Olive.Entities.Data.EF.Replication.csproj b/Olive.Entities.Data.EF.Replication/Olive.Entities.Data.EF.Replication.csproj
@@ -4,7 +4,7 @@
     <TargetFramework>net6.0</TargetFramework>
     <ImplicitUsings>enable</ImplicitUsings>
     <Nullable>enable</Nullable>
-	<Version>1.1.102</Version>
+	<Version>1.1.103</Version>
   </PropertyGroup>
 
   <ItemGroup>

diff --git a/Olive.Entities.Data.EF.Replication/Sync/RefreshMessage.cs b/Olive.Entities.Data.EF.Replication/Sync/RefreshMessage.cs
@@ -7,7 +7,6 @@ class RefreshMessage : IEventBusMessage
         public string TypeName { get; set; }
 
         public string DeduplicationId => TypeName;
-        public string MessageGroupId => "Default";
 
         public DateTime RequestUtc { get; set; }
     }

diff --git a/Olive.Entities.Data.Replication/Olive.Entities.Data.Replication.csproj b/Olive.Entities.Data.Replication/Olive.Entities.Data.Replication.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
-    <Version>2.1.198</Version>
+    <Version>2.1.199</Version>
   </PropertyGroup>
 
   <ItemGroup>

diff --git a/Olive.Entities.Data.Replication/Sync/RefreshMessage.cs b/Olive.Entities.Data.Replication/Sync/RefreshMessage.cs
@@ -7,7 +7,6 @@ class RefreshMessage : IEventBusMessage
         public string TypeName { get; set; }
 
         public string DeduplicationId => TypeName;
-        public string MessageGroupId => "Default";
 
         public DateTime RequestUtc { get; set; }
     }

diff --git a/Olive.EventBus/Message/IEventBusMessage.cs b/Olive.EventBus/Message/IEventBusMessage.cs
@@ -12,6 +12,5 @@ public interface IEventBusMessage
         /// The ID used by queue systems to deduplicate a message in a FIFO (first-in-first-out) queue. (in cases of double delivery).
         /// </summary>
         string DeduplicationId { get; }
-        string MessageGroupId { get; }
     }
 }
diff --git a/Olive.EventBus/Olive.EventBus.csproj b/Olive.EventBus/Olive.EventBus.csproj
@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
   <PropertyGroup>
     <TargetFramework>netstandard2.0</TargetFramework>
-    <Version>2.1.140</Version>
+    <Version>2.1.141</Version>
   </PropertyGroup>
 
   <ItemGroup>