Skip to content

Commit

Permalink
More cleanup
Browse files Browse the repository at this point in the history
  • Loading branch information
danielmarbach committed Sep 11, 2024
1 parent 2cf9da2 commit 0ee2877
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -367,15 +367,15 @@ 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++)
{
var properties = new BasicProperties();
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);
}
},
Expand Down

0 comments on commit 0ee2877

Please sign in to comment.