diff --git a/src/ServiceControl.Transports.Tests/TransportTestFixture.cs b/src/ServiceControl.Transports.Tests/TransportTestFixture.cs index 7c36817a98..0d4f82d592 100644 --- a/src/ServiceControl.Transports.Tests/TransportTestFixture.cs +++ b/src/ServiceControl.Transports.Tests/TransportTestFixture.cs @@ -185,7 +185,7 @@ protected Task CreateTestQueue(string queueName) return configuration.TransportCustomization.ProvisionQueues(transportSettings, []); } - protected static TimeSpan TestTimeout = TimeSpan.FromSeconds(60); + protected static TimeSpan TestTimeout = TimeSpan.FromMinutes(5); protected async Task SendAndReceiveMessages(string queueName, int numMessagesToIngest) { @@ -200,7 +200,7 @@ await StartQueueIngestor( if (numMessagesIngested == numMessagesToIngest) { - onMessagesProcessed.SetResult(true); + onMessagesProcessed.TrySetResult(true); } return Task.CompletedTask;