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");
}