fixup

lukebakken · lukebakken · commit 1fe4a963b933 · 2024-05-20T17:21:46.000-07:00
diff --git a/projects/Test/Integration/ConnectionRecovery/TestExchangeRecovery.cs b/projects/Test/Integration/ConnectionRecovery/TestExchangeRecovery.cs
@@ -70,7 +70,9 @@ public async Task TestExchangeToExchangeBindingRecovery()
             {
                 await CloseAndWaitForRecoveryAsync();
                 Assert.True(_channel.IsOpen);
-                await _channel.BasicPublishAsync(ex_source, RoutingKey.Empty, _encoding.GetBytes("msg"));
+                await _channel.ConfirmSelectAsync();
+                await _channel.BasicPublishAsync(ex_source, RoutingKey.Empty, _encoding.GetBytes("msg"), mandatory: true);
+                await _channel.WaitForConfirmsOrDieAsync();
                 await AssertMessageCountAsync(q, 1);
             }
             finally

Original file line number	Diff line number	Diff line change
`@@ -70,7 +70,9 @@ public async Task TestExchangeToExchangeBindingRecovery()`
`70`	`70`	`{`
`71`	`71`	`await CloseAndWaitForRecoveryAsync();`
`72`	`72`	`Assert.True(_channel.IsOpen);`
`73`		`- await _channel.BasicPublishAsync(ex_source, RoutingKey.Empty, _encoding.GetBytes("msg"));`
	`73`	`+ await _channel.ConfirmSelectAsync();`
	`74`	`+ await _channel.BasicPublishAsync(ex_source, RoutingKey.Empty, _encoding.GetBytes("msg"), mandatory: true);`
	`75`	`+ await _channel.WaitForConfirmsOrDieAsync();`
`74`	`76`	`await AssertMessageCountAsync(q, 1);`
`75`	`77`	`}`
`76`	`78`	`finally`