chore: format

Author: aygalinc

projects/RabbitMQ.Client/ConnectionFactory.cs

@@ -556,7 +556,7 @@ public async Task<IConnection> CreateConnectionAsync(IEndpointResolver endpointR
                 }
                 else
                 {
-                    
+
                     connectionActivity?.SetTag("messaging.rabbitmq.connection.automatic_recovery", false);
                     IFrameHandler frameHandler = await endpointResolver.SelectOneAsync(CreateFrameHandlerAsync, cancellationToken)
                         .ConfigureAwait(false);

projects/RabbitMQ.Client/IEndpointResolverExtensions.cs

@@ -38,7 +38,7 @@ namespace RabbitMQ.Client
 {
     public static class EndpointResolverExtensions
     {
-        public static async Task<T> SelectOneAsync<T>(this IEndpointResolver resolver, 
+        public static async Task<T> SelectOneAsync<T>(this IEndpointResolver resolver,
             Func<AmqpTcpEndpoint, CancellationToken, Task<T>> selector, CancellationToken cancellationToken)
         {
             var exceptions = new List<Exception>();

projects/RabbitMQ.Client/Impl/RabbitMQActivitySource.cs

@@ -72,7 +72,7 @@ public static class RabbitMQActivitySource
             connectionActivity?.SetTag("messaging.rabbitmq.connection.is_reconnection", isReconnection);
             return connectionActivity;
         }
-        
+
         internal static Activity? OpenTcpConnection()
         {
             Activity? connectionActivity =

projects/Test/Common/ActivityRecorder.cs

@@ -144,7 +144,7 @@ public static void HasRecordedException(this Activity activity, Exception except
         {
             activity.HasRecordedException(exception.GetType().ToString());
         }
-        
+
         public static void HasRecordedException(this Activity activity, string exceptionTypeName)
         {
             var exceptionEvent = activity.Events.First();

projects/Test/Integration/TestConnectionFactory.cs

@@ -440,9 +440,9 @@ public async Task TestCreateConnectionAsync_TruncatesWhenClientNameIsLong_GH980(
         public async Task TestCreateConnectionRegisterAnActivity()
         {
             using ActivityRecorder connectionRecorder =
-                new (RabbitMQActivitySource.ConnectionSourceName, "connection attempt");
+                new(RabbitMQActivitySource.ConnectionSourceName, "connection attempt");
             using ActivityRecorder tcpConnectionRecorder =
-                new (RabbitMQActivitySource.ConnectionSourceName, "tcp connection attempt");
+                new(RabbitMQActivitySource.ConnectionSourceName, "tcp connection attempt");
             tcpConnectionRecorder.VerifyParent = false;
             ConnectionFactory cf = CreateConnectionFactory();
             await using IConnection conn = await cf.CreateConnectionAsync();
@@ -456,17 +456,17 @@ public async Task TestCreateConnectionRegisterAnActivity()
         public async Task TestCreateConnectionWithFailureRecordException()
         {
             using ActivityRecorder recorder =
-                new (RabbitMQActivitySource.ConnectionSourceName, "connection attempt");
+                new(RabbitMQActivitySource.ConnectionSourceName, "connection attempt");
             using ActivityRecorder tcpConnectionRecorder =
-                new (RabbitMQActivitySource.ConnectionSourceName, "tcp connection attempt");
+                new(RabbitMQActivitySource.ConnectionSourceName, "tcp connection attempt");
             tcpConnectionRecorder.VerifyParent = false;
             ConnectionFactory cf = CreateConnectionFactory();
             cf.AutomaticRecoveryEnabled = true;
             var unreachablePort = 1234;
             var ep = new AmqpTcpEndpoint("localhost", unreachablePort);
             var exception = await Assert.ThrowsAsync<BrokerUnreachableException>(() =>
             {
-                return cf.CreateConnectionAsync(new List<AmqpTcpEndpoint> {ep});
+                return cf.CreateConnectionAsync(new List<AmqpTcpEndpoint> { ep });
             });
             Activity connectionActivity = recorder.VerifyActivityRecordedOnce();
             connectionActivity.HasRecordedException(exception);