fixup

lukebakken · lukebakken · commit afafcbc0c901 · 2024-05-24T07:15:56.000-07:00
diff --git a/projects/Test/Integration/ConnectionRecovery/TestExchangeRecovery.cs b/projects/Test/Integration/ConnectionRecovery/TestExchangeRecovery.cs
@@ -72,7 +72,7 @@ public async Task TestExchangeToExchangeBindingRecovery()
             {
                 await CloseAndWaitForRecoveryAsync();
                 Assert.True(_channel.IsOpen);
-                await _channel.BasicPublishAsync(ex_source, "", _encoding.GetBytes("msg"));
+                await _channel.BasicPublishAsync(ex_source, "", _encoding.GetBytes("msg"), mandatory: true);
                 await _channel.WaitForConfirmsOrDieAsync();
                 await AssertMessageCountAsync(q, 1);
             }

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