From 0ee2877c601ea3cd77ba5d3f0fe5ee64fa8bff22 Mon Sep 17 00:00:00 2001
From: danielmarbach <danielmarbach@users.noreply.github.com>
Date: Wed, 11 Sep 2024 08:35:41 +0200
Subject: [PATCH] More cleanup

---
 .../MigrateQueue/QueueMigrateToQuorumTests.cs                 | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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<IBasicProperties> 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<IBasicProperties> mod
 
                     modifications?.Invoke(properties);
 
-                    await channel.BasicPublishAsync(string.Empty, queueName, properties, ReadOnlyMemory<byte>.Empty, true, cancellationToken);
+                    await channel.BasicPublishAsync(string.Empty, queueName, true, properties, ReadOnlyMemory<byte>.Empty, cancellationToken);
                     await channel.WaitForConfirmsOrDieAsync(cancellationToken);
                 }
             },