Enable saga and message audit to the .NET Aspire demo (#7591)

ngallegos · web-flow · commit 1aa0e8ce43f9 · 2025-08-01T16:40:25.000-06:00
* Enabled message audit on all endpoints and saga audit where applicable.

* Updated the .NET 10 aspire sample with auditing

* Updated to use the default audit queue

* Added RabbitMQ default management login credentials
diff --git a/samples/hosting/aspire/Core_10/AspireDemo.AppHost/Program.cs b/samples/hosting/aspire/Core_10/AspireDemo.AppHost/Program.cs
@@ -4,7 +4,10 @@
 
 var builder = DistributedApplication.CreateBuilder(args);
 
-var transport = builder.AddRabbitMQ("transport")
+var rabbitUser = builder.AddParameterFromConfiguration("rabbitUser", "RabbitMQ:UserName", true);
+var rabbitPassword = builder.AddParameterFromConfiguration("rabbitPassword", "RabbitMQ:Password", true);
+
+var transport = builder.AddRabbitMQ("transport", rabbitUser, rabbitPassword)
     .WithManagementPlugin(15672)
     .WithUrlForEndpoint("management", url => url.DisplayText = "RabbitMQ Management");
 
diff --git a/samples/hosting/aspire/Core_10/AspireDemo.AppHost/appsettings.json b/samples/hosting/aspire/Core_10/AspireDemo.AppHost/appsettings.json
@@ -5,5 +5,9 @@
       "Microsoft.AspNetCore": "Warning",
       "Aspire.Hosting.Dcp": "Warning"
     }
+  },
+  "RabbitMQ": {
+    "UserName": "guest",
+    "Password": "guest"
   }
 }
diff --git a/samples/hosting/aspire/Core_10/Billing/Program.cs b/samples/hosting/aspire/Core_10/Billing/Program.cs
@@ -14,6 +14,7 @@
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.SendHeartbeatTo("Particular.ServiceControl");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
 
 var metrics = endpointConfiguration.EnableMetrics();
 metrics.SendMetricDataToServiceControl("Particular.Monitoring", TimeSpan.FromSeconds(1));
diff --git a/samples/hosting/aspire/Core_10/ClientUI/Program.cs b/samples/hosting/aspire/Core_10/ClientUI/Program.cs
@@ -18,6 +18,7 @@
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.SendHeartbeatTo("Particular.ServiceControl");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
 
 var metrics = endpointConfiguration.EnableMetrics();
 metrics.SendMetricDataToServiceControl("Particular.Monitoring", TimeSpan.FromSeconds(1));
diff --git a/samples/hosting/aspire/Core_10/Sales/Program.cs b/samples/hosting/aspire/Core_10/Sales/Program.cs
@@ -14,6 +14,7 @@
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.SendHeartbeatTo("Particular.ServiceControl");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
 
 var metrics = endpointConfiguration.EnableMetrics();
 metrics.SendMetricDataToServiceControl("Particular.Monitoring", TimeSpan.FromSeconds(1));
diff --git a/samples/hosting/aspire/Core_10/Shipping/Program.cs b/samples/hosting/aspire/Core_10/Shipping/Program.cs
@@ -39,6 +39,8 @@
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.SendHeartbeatTo("Particular.ServiceControl");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
+endpointConfiguration.AuditSagaStateChanges(serviceControlQueue: "audit");
 
 var metrics = endpointConfiguration.EnableMetrics();
 metrics.SendMetricDataToServiceControl("Particular.Monitoring", TimeSpan.FromSeconds(1));
diff --git a/samples/hosting/aspire/Core_10/Shipping/Shipping.csproj b/samples/hosting/aspire/Core_10/Shipping/Shipping.csproj
@@ -20,6 +20,7 @@
     <PackageReference Include="NServiceBus.Metrics.ServiceControl" Version="6.0.0-alpha.1" />
     <PackageReference Include="NServiceBus.Persistence.Sql" Version="9.0.0-alpha.1" />
     <PackageReference Include="NServiceBus.RabbitMQ" Version="11.0.0-alpha.1" />
+    <PackageReference Include="NServiceBus.SagaAudit" Version="6.0.0-alpha.1" />
   </ItemGroup>
 
 </Project>
diff --git a/samples/hosting/aspire/Core_9/AspireDemo.AppHost/Program.cs b/samples/hosting/aspire/Core_9/AspireDemo.AppHost/Program.cs
@@ -4,7 +4,10 @@
 
 var builder = DistributedApplication.CreateBuilder(args);
 
-var transport = builder.AddRabbitMQ("transport")
+var rabbitUser = builder.AddParameterFromConfiguration("rabbitUser", "RabbitMQ:UserName", true);
+var rabbitPassword = builder.AddParameterFromConfiguration("rabbitPassword", "RabbitMQ:Password", true);
+
+var transport = builder.AddRabbitMQ("transport", rabbitUser, rabbitPassword)
     .WithManagementPlugin(15672)
     .WithUrlForEndpoint("management", url => url.DisplayText = "RabbitMQ Management");
 
diff --git a/samples/hosting/aspire/Core_9/AspireDemo.AppHost/appsettings.json b/samples/hosting/aspire/Core_9/AspireDemo.AppHost/appsettings.json
@@ -5,5 +5,9 @@
       "Microsoft.AspNetCore": "Warning",
       "Aspire.Hosting.Dcp": "Warning"
     }
+  },
+  "RabbitMQ": {
+    "UserName": "guest",
+    "Password": "guest"
   }
 }
diff --git a/samples/hosting/aspire/Core_9/Billing/Program.cs b/samples/hosting/aspire/Core_9/Billing/Program.cs
@@ -14,6 +14,7 @@
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.SendHeartbeatTo("Particular.ServiceControl");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
 
 var metrics = endpointConfiguration.EnableMetrics();
 metrics.SendMetricDataToServiceControl("Particular.Monitoring", TimeSpan.FromSeconds(1));
diff --git a/samples/hosting/aspire/Core_9/ClientUI/Program.cs b/samples/hosting/aspire/Core_9/ClientUI/Program.cs
@@ -18,6 +18,7 @@
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.SendHeartbeatTo("Particular.ServiceControl");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
 
 var metrics = endpointConfiguration.EnableMetrics();
 metrics.SendMetricDataToServiceControl("Particular.Monitoring", TimeSpan.FromSeconds(1));
diff --git a/samples/hosting/aspire/Core_9/Sales/Program.cs b/samples/hosting/aspire/Core_9/Sales/Program.cs
@@ -14,6 +14,7 @@
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.SendHeartbeatTo("Particular.ServiceControl");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
 
 var metrics = endpointConfiguration.EnableMetrics();
 metrics.SendMetricDataToServiceControl("Particular.Monitoring", TimeSpan.FromSeconds(1));
diff --git a/samples/hosting/aspire/Core_9/Shipping/Program.cs b/samples/hosting/aspire/Core_9/Shipping/Program.cs
@@ -39,6 +39,8 @@
 
 endpointConfiguration.UseSerialization<SystemJsonSerializer>();
 endpointConfiguration.SendHeartbeatTo("Particular.ServiceControl");
+endpointConfiguration.AuditProcessedMessagesTo("audit");
+endpointConfiguration.AuditSagaStateChanges(serviceControlQueue: "audit");
 
 var metrics = endpointConfiguration.EnableMetrics();
 metrics.SendMetricDataToServiceControl("Particular.Monitoring", TimeSpan.FromSeconds(1));
diff --git a/samples/hosting/aspire/Core_9/Shipping/Shipping.csproj b/samples/hosting/aspire/Core_9/Shipping/Shipping.csproj
@@ -20,6 +20,7 @@
     <PackageReference Include="NServiceBus.Metrics.ServiceControl" Version="5.*" />
     <PackageReference Include="NServiceBus.Persistence.Sql" Version="8.*" />
     <PackageReference Include="NServiceBus.RabbitMQ" Version="10.*" />
+    <PackageReference Include="NServiceBus.SagaAudit" Version="5.*" />
   </ItemGroup>
 
 </Project>

Original file line number	Diff line number	Diff line change
`@@ -5,5 +5,9 @@`
`5`	`5`	`"Microsoft.AspNetCore": "Warning",`
`6`	`6`	`"Aspire.Hosting.Dcp": "Warning"`
`7`	`7`	`}`
	`8`	`+ },`
	`9`	`+ "RabbitMQ": {`
	`10`	`+ "UserName": "guest",`
	`11`	`+ "Password": "guest"`
`8`	`12`	`}`
`9`	`13`	`}`