Always call VerifyRequirements on startup

Particular · Feb 5, 2025 · 42dbd2c · 42dbd2c
1 parent 60e705b
commit 42dbd2c
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 2 deletions.
diff --git a/src/NServiceBus.Transport.RabbitMQ/RabbitMQTransport.cs b/src/NServiceBus.Transport.RabbitMQ/RabbitMQTransport.cs
@@ -232,6 +232,7 @@ public override async Task<TransportInfrastructure> Initialize(HostSettings host
 
             var brokerVerifier = new BrokerVerifier(ManagementClient, ValidateDeliveryLimits);
             await brokerVerifier.Initialize(cancellationToken).ConfigureAwait(false);
+            await brokerVerifier.VerifyRequirements(cancellationToken).ConfigureAwait(false);
 
             var channelProvider = new ChannelProvider(connectionFactory, NetworkRecoveryInterval, RoutingTopology);
             await channelProvider.CreateConnection(cancellationToken).ConfigureAwait(false);

diff --git a/src/NServiceBus.Transport.RabbitMQ/RabbitMQTransportInfrastructure.cs b/src/NServiceBus.Transport.RabbitMQ/RabbitMQTransportInfrastructure.cs
@@ -50,8 +50,6 @@ internal async Task SetupInfrastructure(string[] sendingQueues, CancellationToke
         {
             using var connection = await connectionFactory.CreateAdministrationConnection(cancellationToken).ConfigureAwait(false);
 
-            await brokerVerifier.VerifyRequirements(cancellationToken).ConfigureAwait(false);
-
             using var channel = await connection.CreateChannelAsync(cancellationToken: cancellationToken).ConfigureAwait(false);
 
             if (supportsDelayedDelivery)