Add recoverability config for Monitoring instance

Particular · Mar 4, 2024 · 252d080 · 252d080
1 parent 69788f8
commit 252d080
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 deletions.
diff --git a/src/ServiceControl.Monitoring/WebApplicationBuilderExtensions.cs b/src/ServiceControl.Monitoring/WebApplicationBuilderExtensions.cs
@@ -111,7 +111,13 @@ internal static void ConfigureEndpoint(EndpointConfiguration config, Func<ICriti
 
         config.UseSerialization<NewtonsoftJsonSerializer>();
         config.UsePersistence<NonDurablePersistence>();
+
+        var recoverability = config.Recoverability();
+        recoverability.Immediate(c => c.NumberOfRetries(3));
+        recoverability.Delayed(c => c.NumberOfRetries(0));
+
         config.SendFailedMessagesTo(settings.ErrorQueue);
+
         config.DisableFeature<AutoSubscribe>();
 
         config.AddDeserializer<TaggedLongValueWriterOccurrenceSerializerDefinition>();

diff --git a/src/ServiceControl/Infrastructure/NServiceBusFactory.cs b/src/ServiceControl/Infrastructure/NServiceBusFactory.cs
@@ -39,6 +39,7 @@ static class NServiceBusFactory
             recoverability.Immediate(c => c.NumberOfRetries(3));
             recoverability.Delayed(c => c.NumberOfRetries(0));
             recoverability.AddUnrecoverableException<UnrecoverableException>();
+
             configuration.SendFailedMessagesTo(transportSettings.ErrorQueue);
 
             recoverability.CustomPolicy(SendEmailNotificationHandler.RecoverabilityPolicy);