* Fix test

lukebakken · lukebakken · commit e20cc264b300 · 2024-05-21T10:55:42.000-07:00
diff --git a/projects/Test/Integration/TestAsyncConsumer.cs b/projects/Test/Integration/TestAsyncConsumer.cs
@@ -452,8 +452,6 @@ public async Task TestBasicAckAsync()
                 });
             };
 
-            await _channel.ConfirmSelectAsync();
-
             var consumer = new AsyncEventingBasicConsumer(_channel);
             consumer.Received += async (object sender, BasicDeliverEventArgs args) =>
             {
@@ -478,6 +476,8 @@ await _channel.BasicConsumeAsync(queue: queueName, autoAck: false,
             {
                 using (IChannel publishChannel = await _conn.CreateChannelAsync())
                 {
+                    await publishChannel.ConfirmSelectAsync();
+
                     for (int i = 0; i < messageCount; i++)
                     {
                         byte[] _body = _encoding.GetBytes(Guid.NewGuid().ToString());

Original file line number	Diff line number	Diff line change
`@@ -452,8 +452,6 @@ public async Task TestBasicAckAsync()`
`452`	`452`	`});`
`453`	`453`	`};`
`454`	`454`
`455`		`- await _channel.ConfirmSelectAsync();`
`456`		`-`
`457`	`455`	`var consumer = new AsyncEventingBasicConsumer(_channel);`
`458`	`456`	`consumer.Received += async (object sender, BasicDeliverEventArgs args) =>`
`459`	`457`	`{`
`@@ -478,6 +476,8 @@ await _channel.BasicConsumeAsync(queue: queueName, autoAck: false,`
`478`	`476`	`{`
`479`	`477`	`using (IChannel publishChannel = await _conn.CreateChannelAsync())`
`480`	`478`	`{`
	`479`	`+ await publishChannel.ConfirmSelectAsync();`
	`480`	`+`
`481`	`481`	`for (int i = 0; i < messageCount; i++)`
`482`	`482`	`{`
`483`	`483`	`byte[] _body = _encoding.GetBytes(Guid.NewGuid().ToString());`