diff --git a/Directory.Packages.props b/Directory.Packages.props index a68c04e..1cc3dda 100644 --- a/Directory.Packages.props +++ b/Directory.Packages.props @@ -3,9 +3,9 @@ true - + - + @@ -15,16 +15,16 @@ - + - - - - - + + + + + @@ -56,8 +56,8 @@ - - + + \ No newline at end of file diff --git a/MessagingService.IntegrationTests/Common/DockerHelper.cs b/MessagingService.IntegrationTests/Common/DockerHelper.cs index 8502fea..9c34871 100644 --- a/MessagingService.IntegrationTests/Common/DockerHelper.cs +++ b/MessagingService.IntegrationTests/Common/DockerHelper.cs @@ -63,7 +63,7 @@ public DockerHelper() #region Methods - public override async Task CreateSubscriptions(){ + public override async Task CreateSubscriptions(CancellationToken cancellationToken){ List<(String streamName, String groupName, Int32 maxRetries)> subscriptions = SubscriptionsHelper.GetSubscriptions(); foreach ((String streamName, String groupName, Int32 maxRetries) subscription in subscriptions) { @@ -73,8 +73,9 @@ public override async Task CreateSubscriptions(){ public String AccessToken; - public override async Task StartContainersForScenarioRun(String scenarioName, DockerServices dockerServices){ - await base.StartContainersForScenarioRun(scenarioName, dockerServices); + public override async Task StartContainersForScenarioRun(String scenarioName, DockerServices dockerServices, CancellationToken cancellationToken) + { + await base.StartContainersForScenarioRun(scenarioName, dockerServices, cancellationToken); // Setup the base address resolvers String SecurityServiceBaseAddressResolver(String api) => $"https://127.0.0.1:{this.SecurityServicePort}"; diff --git a/MessagingService.IntegrationTests/Common/GenericSteps.cs b/MessagingService.IntegrationTests/Common/GenericSteps.cs index cae43ea..86cc8ac 100644 --- a/MessagingService.IntegrationTests/Common/GenericSteps.cs +++ b/MessagingService.IntegrationTests/Common/GenericSteps.cs @@ -9,6 +9,7 @@ namespace MessagingService.IntegrationTests.Common { using Reqnroll; + using System.Threading; [Binding] [Scope(Tag = "base")] @@ -53,7 +54,7 @@ public async Task StartSystem() this.TestingContext.Logger = logger; this.TestingContext.Logger.LogInformation("About to Start Containers for Scenario Run"); - await this.TestingContext.DockerHelper.StartContainersForScenarioRun(scenarioName, dockerServices).ConfigureAwait(false); + await this.TestingContext.DockerHelper.StartContainersForScenarioRun(scenarioName, dockerServices, CancellationToken.None).ConfigureAwait(false); this.TestingContext.Logger.LogInformation("Containers for Scenario Run Started"); }