chore: format

Author: aygalinc

RabbitMQ.AMQP.Client/Impl/AmqpConnection.cs

@@ -38,7 +38,7 @@ public class AmqpConnection : AbstractLifeCycle, IConnection
         internal readonly IConnectionSettings _connectionSettings;
         private readonly IMetricsReporter _metricsReporter;
         internal readonly AmqpSessionManagement _nativePubSubSessions;
- 
+
         /// <summary>
         /// Publishers contains all the publishers created by the connection.
         /// Each connection can have multiple publishers.

RabbitMQ.AMQP.Client/Impl/AmqpConsumer.cs

@@ -159,10 +159,10 @@ private async Task ProcessMessages()
 
                     IContext context = new DeliveryContext(_receiverLink, nativeMessage, _unsettledMessageCounter);
                     var amqpMessage = new AmqpMessage(nativeMessage);
-                    
+
                     // TODO catch exceptions thrown by handlers,
                     // then call exception handler?
-                    
+
                     if (_configuration.Handler != null)
                     {
                         await _configuration.Handler(context, amqpMessage).ConfigureAwait(false);
@@ -176,7 +176,7 @@ private async Task ProcessMessages()
                 {
                     return;
                 }
-                
+
                 Trace.WriteLine(TraceLevel.Error, $"{ToString()} Failed to process messages, {e}");
                 // TODO this is where a Listener should get a closed event
                 // See the ConsumerShouldBeClosedWhenQueueIsDeleted test

RabbitMQ.AMQP.Client/Impl/AmqpEnvironment.cs

@@ -32,7 +32,7 @@ public static Task<IEnvironment> CreateAsync(IConnectionSettings connectionSetti
 
         public async Task<IConnection> CreateConnectionAsync(IConnectionSettings connectionSettings)
         {
-            IConnection c = await AmqpConnection.CreateAsync(connectionSettings,_metricsReporter).ConfigureAwait(false);
+            IConnection c = await AmqpConnection.CreateAsync(connectionSettings, _metricsReporter).ConfigureAwait(false);
             c.Id = Interlocked.Increment(ref _sequentialId);
             _connections.TryAdd(c.Id, c);
             c.ChangeState += (sender, previousState, currentState, failureCause) =>

RabbitMQ.AMQP.Client/Impl/AmqpPublisherBuilder.cs

@@ -69,7 +69,7 @@ public async Task<IPublisher> BuildAsync(CancellationToken cancellationToken = d
             {
                 address = AddressBuilderHelper.AddressBuilder().Exchange(_exchange).Queue(_queue).Key(_key).Address();
             }
-            
+
             AmqpPublisher publisher = new(_connection, address, _metricsReporter, _timeout);
 
             // TODO pass cancellationToken

Tests/Consumer/ConsumerMetricsTests.cs

@@ -46,7 +46,6 @@ public async Task RecordMessageDeliverySuccessAndDuration()
 
         await WhenTcsCompletes(tcs);
 
-
         var consumedMessagesMeasurements = messageConsumedCollector.GetMeasurementSnapshot();
         Assert.NotEmpty(consumedMessagesMeasurements);
         Assert.Equal(1, consumedMessagesMeasurements[0].Value);

Tests/IntegrationTest.cs

@@ -36,7 +36,6 @@ public abstract class IntegrationTest : IAsyncLifetime
     private readonly bool _setupConnectionAndManagement;
     protected readonly ConnectionSettingBuilder _connectionSettingBuilder;
 
-    
     public IntegrationTest(ITestOutputHelper testOutputHelper,
         bool setupConnectionAndManagement = true)
     {
@@ -65,7 +64,7 @@ public virtual async Task InitializeAsync()
             _meterFactory = serviceProvider.GetRequiredService<IMeterFactory>();
 #endif
             _connectionSettings = _connectionSettingBuilder.Build();
-            _connection = await AmqpConnection.CreateAsync(_connectionSettings,_metricsReporter);
+            _connection = await AmqpConnection.CreateAsync(_connectionSettings, _metricsReporter);
             _management = _connection.Management();
         }