Update async/await for createConnection

Travis Nickels · bording · commit ff95bc505429 · 2025-02-26T11:26:45.000-05:00
diff --git a/src/ServiceControl.Transports.RabbitMQ/QueueLengthProvider.cs b/src/ServiceControl.Transports.RabbitMQ/QueueLengthProvider.cs
@@ -124,7 +124,7 @@ public async Task Execute(Action<IChannel> action, CancellationToken cancellatio
             {
                 try
                 {
-                    connection ??= connectionFactory.CreateConnection("queue length monitor");
+                    connection ??= await connectionFactory.CreateConnection("queue length monitor", cancellationToken: cancellationToken);
 
                     //Connection implements reconnection logic
                     while (!connection.IsOpen)

Original file line number	Diff line number	Diff line change
`@@ -124,7 +124,7 @@ public async Task Execute(Action<IChannel> action, CancellationToken cancellatio`
`124`	`124`	`{`
`125`	`125`	`try`
`126`	`126`	`{`
`127`		`- connection ??= connectionFactory.CreateConnection("queue length monitor");`
	`127`	`+ connection ??= await connectionFactory.CreateConnection("queue length monitor", cancellationToken: cancellationToken);`
`128`	`128`
`129`	`129`	`//Connection implements reconnection logic`
`130`	`130`	`while (!connection.IsOpen)`