Skip to content

Commit a24d18b

Browse files
authored
Merge pull request #6954 from Particular/sc-eventing-custom-queue
Warning about custom error queue when doing ServiceControl integration
2 parents 77dfdcb + c2fe525 commit a24d18b

File tree

4 files changed

+16
-3
lines changed
  • samples/servicecontrol/events-subscription

4 files changed

+16
-3
lines changed

samples/servicecontrol/events-subscription/ServiceControlContracts_3/EndpointsMonitor/Program.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,10 @@ static async Task Main()
1111
endpointConfiguration.UseSerialization<NewtonsoftJsonSerializer>();
1212
endpointConfiguration.EnableInstallers();
1313
endpointConfiguration.UsePersistence<InMemoryPersistence>();
14-
endpointConfiguration.SendFailedMessagesTo("error");
14+
15+
#region ServiceControlEventsMonitorCustomErrorQueue
16+
endpointConfiguration.SendFailedMessagesTo("error-monitoring");
17+
#endregion
1518

1619
var transport = endpointConfiguration.UseTransport<LearningTransport>();
1720

samples/servicecontrol/events-subscription/ServiceControlContracts_4/EndpointsMonitor/Program.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,10 @@ static async Task Main()
1111
endpointConfiguration.UseSerialization<NewtonsoftJsonSerializer>();
1212
endpointConfiguration.EnableInstallers();
1313
endpointConfiguration.UsePersistence<NonDurablePersistence>();
14-
endpointConfiguration.SendFailedMessagesTo("error");
14+
15+
#region ServiceControlEventsMonitorCustomErrorQueue
16+
endpointConfiguration.SendFailedMessagesTo("error-monitoring");
17+
#endregion
1518

1619
var transport = endpointConfiguration.UseTransport<LearningTransport>();
1720

samples/servicecontrol/events-subscription/ServiceControlContracts_5/EndpointsMonitor/Program.cs

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,10 @@ static async Task Main()
1111
endpointConfiguration.UseSerialization<NewtonsoftJsonSerializer>();
1212
endpointConfiguration.EnableInstallers();
1313
endpointConfiguration.UsePersistence<NonDurablePersistence>();
14-
endpointConfiguration.SendFailedMessagesTo("error");
14+
15+
#region ServiceControlEventsMonitorCustomErrorQueue
16+
endpointConfiguration.SendFailedMessagesTo("error-monitoring");
17+
#endregion
1518

1619
var transport = endpointConfiguration.UseTransport<LearningTransport>();
1720

samples/servicecontrol/events-subscription/sample.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,10 @@ In order to get notifications when the exposed ServiceControl events occur, crea
8585

8686
snippet: ServiceControlEventsHandlers
8787

88+
> [!IMPORTANT]
89+
> In order to prevent infinate message loops (processing of an integration event fails, the faulting message is moved to the ServiceControl error queue and triggers yet another integration event) the monitoring endpoint must use a dedicated error queue, separte from the ServiceControl one.
90+
91+
snippet: ServiceControlEventsMonitorCustomErrorQueue
8892

8993
## Notes on other transports
9094

0 commit comments

Comments
 (0)