Skip to content

Commit b2e52d9

Browse files
committed
More cleanup
1 parent 54faa81 commit b2e52d9

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/NServiceBus.Transport.RabbitMQ.CommandLine.Tests/MigrateQueue/QueueMigrateToQuorumTests.cs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -367,15 +367,15 @@ Task AddMessages(string queueName, int numMessages, Action<IBasicProperties> mod
367367
{
368368
return ExecuteBrokerCommand(async (channel, cancellationToken) =>
369369
{
370-
await channel.ConfirmSelectAsync(cancellationToken);
370+
await channel.ConfirmSelectAsync(trackConfirmations: true, cancellationToken);
371371

372372
for (var i = 0; i < numMessages; i++)
373373
{
374374
var properties = new BasicProperties();
375375

376376
modifications?.Invoke(properties);
377377

378-
await channel.BasicPublishAsync(string.Empty, queueName, properties, ReadOnlyMemory<byte>.Empty, true, cancellationToken);
378+
await channel.BasicPublishAsync(string.Empty, queueName, true, properties, ReadOnlyMemory<byte>.Empty, cancellationToken);
379379
await channel.WaitForConfirmsOrDieAsync(cancellationToken);
380380
}
381381
},

0 commit comments

Comments
 (0)