Merge pull request #309 from TransactionProcessing/nightly/#305_addretrytoreportingsubscription

StuartFerguson · web-flow · commit 264de4bb3712 · 2022-07-26T10:56:23.000+01:00
Added a few retries to the reporting subscription
diff --git a/TransactionProcessor.IntegrationTests/Common/DockerHelper.cs b/TransactionProcessor.IntegrationTests/Common/DockerHelper.cs
@@ -103,7 +103,7 @@ public DockerHelper(NlogLogger logger,
         public async Task PopulateSubscriptionServiceConfiguration(String estateName, Boolean isSecureEventStore)
         {
             List<(String streamName, String groupName, Int32 maxRetries)> subscriptions = new List<(String streamName, String groupName, Int32 maxRetries)>();
-            subscriptions.Add((estateName.Replace(" ", ""), "Reporting",0));
+            subscriptions.Add((estateName.Replace(" ", ""), "Reporting",2));
             subscriptions.Add(($"EstateManagementSubscriptionStream_{estateName.Replace(" ", "")}", "Estate Management",0));
             subscriptions.Add(($"TransactionProcessorSubscriptionStream_{estateName.Replace(" ", "")}", "Transaction Processor",0));
             await this.PopulateSubscriptionServiceConfiguration(this.EventStoreHttpPort, subscriptions, isSecureEventStore);

Original file line number	Diff line number	Diff line change
`@@ -103,7 +103,7 @@ public DockerHelper(NlogLogger logger,`
`103`	`103`	`public async Task PopulateSubscriptionServiceConfiguration(String estateName, Boolean isSecureEventStore)`
`104`	`104`	`{`
`105`	`105`	`List<(String streamName, String groupName, Int32 maxRetries)> subscriptions = new List<(String streamName, String groupName, Int32 maxRetries)>();`
`106`		`- subscriptions.Add((estateName.Replace(" ", ""), "Reporting",0));`
	`106`	`+ subscriptions.Add((estateName.Replace(" ", ""), "Reporting",2));`
`107`	`107`	`subscriptions.Add(($"EstateManagementSubscriptionStream_{estateName.Replace(" ", "")}", "Estate Management",0));`
`108`	`108`	`subscriptions.Add(($"TransactionProcessorSubscriptionStream_{estateName.Replace(" ", "")}", "Transaction Processor",0));`
`109`	`109`	`await this.PopulateSubscriptionServiceConfiguration(this.EventStoreHttpPort, subscriptions, isSecureEventStore);`