SlimMessageBus.Host.Outbox.Memory that deffers sending of messages un…

…til unit of work commits Signed-off-by: Tomasz Maruszak <[email protected]>
zarusz · Oct 16, 2024 · d963fc6 · d963fc6
1 parent 19118b9
commit d963fc6
Show file tree

Hide file tree

Showing 5 changed files with 33 additions and 2 deletions.
diff --git a/build/tasks.ps1 b/build/tasks.ps1
@@ -40,6 +40,7 @@ $projects = @(
 
 	"SlimMessageBus.Host.Outbox",
 	"SlimMessageBus.Host.Outbox.DbContext",
+	"SlimMessageBus.Host.Outbox.Memory",
 	"SlimMessageBus.Host.Outbox.Sql",
 	"SlimMessageBus.Host.Outbox.Sql.DbContext",
 

diff --git a/src/SlimMessageBus.Host.Outbox.DbContext/SlimMessageBus.Host.Outbox.DbContext.csproj b/src/SlimMessageBus.Host.Outbox.DbContext/SlimMessageBus.Host.Outbox.DbContext.csproj
@@ -17,5 +17,4 @@
     <PackageReference Include="Microsoft.EntityFrameworkCore.Relational" Version="8.0.0" Condition="'$(TargetFramework)' == 'net8.0'" />
   </ItemGroup>
 
-
 </Project>
diff --git a/src/SlimMessageBus.Host.Outbox.Memory/Configuration/MemoryOutboxSettings.cs b/src/SlimMessageBus.Host.Outbox.Memory/Configuration/MemoryOutboxSettings.cs
@@ -0,0 +1,6 @@
+namespace SlimMessageBus.Host.Outbox.Memory;
+
+public class MemoryOutboxSettings
+{
+
+}
diff --git a/src/SlimMessageBus.Host.Outbox.Memory/SlimMessageBus.Host.Outbox.Memory.csproj b/src/SlimMessageBus.Host.Outbox.Memory/SlimMessageBus.Host.Outbox.Memory.csproj
@@ -0,0 +1,14 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <Import Project="../Host.Plugin.Properties.xml" />
+
+  <PropertyGroup>
+    <Description>Plugin for SlimMessageBus that adds Outbox pattern support that deffers message delivery until transaction commits. Messages are buffered in memory.</Description>
+    <PackageTags>SlimMessageBus MessageBus Outbox Memory</PackageTags>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\SlimMessageBus.Host.Outbox\SlimMessageBus.Host.Outbox.csproj" />
+  </ItemGroup>
+
+</Project>
diff --git a/src/SlimMessageBus.sln b/src/SlimMessageBus.sln
@@ -279,7 +279,9 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Nats-SingleNode", "Nats-Sin
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "SlimMessageBus.Host.AspNetCore.Test", "Tests\SlimMessageBus.Host.AspNetCore.Test\SlimMessageBus.Host.AspNetCore.Test.csproj", "{9FCBF788-1F0C-43E2-909D-1F96B2685F38}"
 EndProject
-Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SlimMessageBus.Host.Outbox.DbContext", "SlimMessageBus.Host.Outbox.DbContext\SlimMessageBus.Host.Outbox.DbContext.csproj", "{3373FC58-73A7-46E6-9CB9-0858660EAD52}"
+Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "SlimMessageBus.Host.Outbox.DbContext", "SlimMessageBus.Host.Outbox.DbContext\SlimMessageBus.Host.Outbox.DbContext.csproj", "{3373FC58-73A7-46E6-9CB9-0858660EAD52}"
+EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "SlimMessageBus.Host.Outbox.Memory", "SlimMessageBus.Host.Outbox.Memory\SlimMessageBus.Host.Outbox.Memory.csproj", "{D0CC7072-1E1B-4FCA-A253-630035757FA2}"
 EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
@@ -857,6 +859,14 @@ Global
 		{3373FC58-73A7-46E6-9CB9-0858660EAD52}.Release|Any CPU.Build.0 = Release|Any CPU
 		{3373FC58-73A7-46E6-9CB9-0858660EAD52}.Release|x86.ActiveCfg = Release|Any CPU
 		{3373FC58-73A7-46E6-9CB9-0858660EAD52}.Release|x86.Build.0 = Release|Any CPU
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2}.Debug|x86.ActiveCfg = Debug|Any CPU
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2}.Debug|x86.Build.0 = Debug|Any CPU
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2}.Release|Any CPU.Build.0 = Release|Any CPU
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2}.Release|x86.ActiveCfg = Release|Any CPU
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2}.Release|x86.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE
@@ -941,6 +951,7 @@ Global
 		{5250E48D-36C7-4214-8D7E-5924A9E337C6} = {59F88FB5-6D19-4520-87E8-227B3539BBB3}
 		{9FCBF788-1F0C-43E2-909D-1F96B2685F38} = {9F005B5C-A856-4351-8C0C-47A8B785C637}
 		{3373FC58-73A7-46E6-9CB9-0858660EAD52} = {B7CDA0D2-98AB-42B6-A41A-9D893C1B9DCB}
+		{D0CC7072-1E1B-4FCA-A253-630035757FA2} = {B7CDA0D2-98AB-42B6-A41A-9D893C1B9DCB}
 	EndGlobalSection
 	GlobalSection(ExtensibilityGlobals) = postSolution
 		SolutionGuid = {435A0D65-610C-4B84-B1AA-2C7FBE72DB80}