* Add publisher confirmations to PublishMessagesWhileClosingConnAsync

lukebakken · lukebakken · commit e9e59a890c29 · 2024-05-09T10:55:54.000-07:00
diff --git a/projects/Test/Common/TestConnectionRecoveryBase.cs b/projects/Test/Common/TestConnectionRecoveryBase.cs
@@ -202,6 +202,8 @@ protected async Task PublishMessagesWhileClosingConnAsync(string queueName)
             {
                 using (IChannel publishingChannel = await publishingConn.CreateChannelAsync())
                 {
+                    await publishingChannel.ConfirmSelectAsync();
+
                     for (ushort i = 0; i < TotalMessageCount; i++)
                     {
                         if (i == CloseAtCount)
@@ -210,6 +212,7 @@ protected async Task PublishMessagesWhileClosingConnAsync(string queueName)
                         }
 
                         await publishingChannel.BasicPublishAsync(string.Empty, queueName, _messageBody);
+                        await publishingChannel.WaitForConfirmsOrDieAsync();
                     }
 
                     await publishingChannel.CloseAsync();

Original file line number	Diff line number	Diff line change
`@@ -202,6 +202,8 @@ protected async Task PublishMessagesWhileClosingConnAsync(string queueName)`
`202`	`202`	`{`
`203`	`203`	`using (IChannel publishingChannel = await publishingConn.CreateChannelAsync())`
`204`	`204`	`{`
	`205`	`+ await publishingChannel.ConfirmSelectAsync();`
	`206`	`+`
`205`	`207`	`for (ushort i = 0; i < TotalMessageCount; i++)`
`206`	`208`	`{`
`207`	`209`	`if (i == CloseAtCount)`
`@@ -210,6 +212,7 @@ protected async Task PublishMessagesWhileClosingConnAsync(string queueName)`
`210`	`212`	`}`
`211`	`213`
`212`	`214`	`await publishingChannel.BasicPublishAsync(string.Empty, queueName, _messageBody);`
	`215`	`+ await publishingChannel.WaitForConfirmsOrDieAsync();`
`213`	`216`	`}`
`214`	`217`
`215`	`218`	`await publishingChannel.CloseAsync();`