AutorecoveringChannel use token

danielmarbach · danielmarbach · commit 3459cb94f2cd · 2024-09-11T11:26:07.000+02:00
diff --git a/projects/RabbitMQ.Client/client/impl/AutorecoveringChannel.cs b/projects/RabbitMQ.Client/client/impl/AutorecoveringChannel.cs
@@ -197,7 +197,7 @@ await newChannel.TxSelectAsync(cancellationToken)
 
             if (_disposed)
             {
-                await newChannel.AbortAsync()
+                await newChannel.AbortAsync(CancellationToken.None)
                     .ConfigureAwait(false);
                 return false;
             }
@@ -207,7 +207,7 @@ await newChannel.AbortAsync()
 
                 if (recoverConsumers)
                 {
-                    await _connection.RecoverConsumersAsync(this, newChannel, recordedEntitiesSemaphoreHeld)
+                    await _connection.RecoverConsumersAsync(this, newChannel, recordedEntitiesSemaphoreHeld, cancellationToken)
                         .ConfigureAwait(false);
                 }
 

Original file line number	Diff line number	Diff line change
`@@ -197,7 +197,7 @@ await newChannel.TxSelectAsync(cancellationToken)`
`197`	`197`
`198`	`198`	`if (_disposed)`
`199`	`199`	`{`
`200`		`- await newChannel.AbortAsync()`
	`200`	`+ await newChannel.AbortAsync(CancellationToken.None)`
`201`	`201`	`.ConfigureAwait(false);`
`202`	`202`	`return false;`
`203`	`203`	`}`
`@@ -207,7 +207,7 @@ await newChannel.AbortAsync()`
`207`	`207`
`208`	`208`	`if (recoverConsumers)`
`209`	`209`	`{`
`210`		`- await _connection.RecoverConsumersAsync(this, newChannel, recordedEntitiesSemaphoreHeld)`
	`210`	`+ await _connection.RecoverConsumersAsync(this, newChannel, recordedEntitiesSemaphoreHeld, cancellationToken)`
`211`	`211`	`.ConfigureAwait(false);`
`212`	`212`	`}`
`213`	`213`