diff --git a/src/NServiceBus.Transport.RabbitMQ.CommandLine.Tests/MigrateQueue/QueueMigrateToQuorumTests.cs b/src/NServiceBus.Transport.RabbitMQ.CommandLine.Tests/MigrateQueue/QueueMigrateToQuorumTests.cs index 09f18dfce..d541dc8f5 100644 --- a/src/NServiceBus.Transport.RabbitMQ.CommandLine.Tests/MigrateQueue/QueueMigrateToQuorumTests.cs +++ b/src/NServiceBus.Transport.RabbitMQ.CommandLine.Tests/MigrateQueue/QueueMigrateToQuorumTests.cs @@ -367,7 +367,7 @@ Task AddMessages(string queueName, int numMessages, Action mod { return ExecuteBrokerCommand(async (channel, cancellationToken) => { - await channel.ConfirmSelectAsync(cancellationToken); + await channel.ConfirmSelectAsync(trackConfirmations: true, cancellationToken); for (var i = 0; i < numMessages; i++) { @@ -375,7 +375,7 @@ Task AddMessages(string queueName, int numMessages, Action mod modifications?.Invoke(properties); - await channel.BasicPublishAsync(string.Empty, queueName, properties, ReadOnlyMemory.Empty, true, cancellationToken); + await channel.BasicPublishAsync(string.Empty, queueName, true, properties, ReadOnlyMemory.Empty, cancellationToken); await channel.WaitForConfirmsOrDieAsync(cancellationToken); } },