Made a codacy code style fixing

Author: antonyvorontsov

src/Examples.ConsumerHost/CustomNonCyclicMessageHandler.cs

@@ -6,8 +6,10 @@ namespace Examples.ConsumerHost
     public class CustomNonCyclicMessageHandler : INonCyclicMessageHandler
     {
         readonly ILogger<CustomNonCyclicMessageHandler> _logger;
-        public CustomNonCyclicMessageHandler(ILogger<CustomNonCyclicMessageHandler> logger) =>
+        public CustomNonCyclicMessageHandler(ILogger<CustomNonCyclicMessageHandler> logger)
+        {
             _logger = logger;
+        }
 
         public void Handle(string message, string routingKey, IQueueService queueService)
         {

src/RabbitMQ.Client.Core.DependencyInjection/Configuration/RabbitMqClientOptions.cs

@@ -8,7 +8,7 @@ public class RabbitMqClientOptions
         /// <summary>
         /// RabbitMQ server.
         /// </summary>
-        public string HostName { get; set; } = "127.0.0.1";
+        public string HostName { get; set; }
 
         /// <summary>
         /// Port.

src/RabbitMQ.Client.Core.DependencyInjection/Configuration/RabbitMqQueueOptions.cs

@@ -20,12 +20,12 @@ public class RabbitMqQueueOptions
         /// <summary>
         /// Exclusive option.
         /// </summary>
-        public bool Exclusive { get; set; } = false;
+        public bool Exclusive { get; set; }
 
         /// <summary>
         /// AutoDelete option.
         /// </summary>
-        public bool AutoDelete { get; set; } = false;
+        public bool AutoDelete { get; set; }
 
         /// <summary>
         /// Routing keys collection that queue "listens".

src/RabbitMQ.Client.Core.DependencyInjection/QueueService.cs

@@ -15,7 +15,7 @@ namespace RabbitMQ.Client.Core.DependencyInjection
     /// <summary>
     /// Implementation of the custom RabbitMQ queue service.
     /// </summary>
-    internal class QueueService : IQueueService
+    internal class QueueService : IQueueService, IDisposable
     {
         /// <summary>
         /// RabbitMQ connection.
@@ -56,7 +56,9 @@ public QueueService(
             IOptions<RabbitMqClientOptions> options)
         {
             if (options is null)
+            {
                 throw new ArgumentException($"Argument {nameof(options)} is null.", nameof(options));
+            }
 
             _exchanges = exchanges;
 
@@ -103,17 +105,22 @@ public void Dispose()
                 _connection.CallbackException -= HandleConnectionCallbackException;
                 _connection.ConnectionRecoveryError -= HandleConnectionRecoveryError;
             }
+
             if (_channel != null)
             {
                 _channel.CallbackException -= HandleChannelCallbackException;
                 _channel.BasicRecoverOk -= HandleChannelBasicRecoverOk;
             }
 
             if (_channel?.IsOpen == true)
+            {
                 _channel.Close((int)HttpStatusCode.OK, "Channel closed");
+            }
 
             if (_connection?.IsOpen == true)
+            {
                 _connection.Close();
+            }
         }
 
         /// <summary>
@@ -122,7 +129,9 @@ public void Dispose()
         public void StartConsuming()
         {
             if (_consumingStarted)
+            {
                 return;
+            }
 
             _consumer.Received += _receivedMessage;
             _consumingStarted = true;
@@ -246,7 +255,9 @@ IBasicProperties CreateJsonProperties()
         void HandleConnectionCallbackException(object sender, CallbackExceptionEventArgs @event)
         {
             if (@event is null)
+            {
                 return;
+            }
 
             _logger.LogError(new EventId(), @event.Exception, @event.Exception.Message, @event);
             throw @event.Exception;
@@ -255,7 +266,9 @@ void HandleConnectionCallbackException(object sender, CallbackExceptionEventArgs
         void HandleConnectionRecoveryError(object sender, ConnectionRecoveryErrorEventArgs @event)
         {
             if (@event is null)
+            {
                 return;
+            }
 
             _logger.LogError(new EventId(), @event.Exception, @event.Exception.Message, @event);
             throw @event.Exception;
@@ -264,15 +277,19 @@ void HandleConnectionRecoveryError(object sender, ConnectionRecoveryErrorEventAr
         void HandleChannelBasicRecoverOk(object sender, EventArgs @event)
         {
             if (@event is null)
+            {
                 return;
+            }
 
             _logger.LogInformation("Connection has been reestablished.");
         }
 
         void HandleChannelCallbackException(object sender, CallbackExceptionEventArgs @event)
         {
             if (@event is null)
+            {
                 return;
+            }
 
             _logger.LogError(new EventId(), @event.Exception, @event.Exception.Message, @event);
         }
@@ -311,7 +328,7 @@ IDictionary<string, IList<T>> TransformMessageHandlersCollection<T>(IEnumerable<
                     }
                     else
                     {
-                        dictionary.Add(routingKey, new List<T>() { handler });
+                        dictionary.Add(routingKey, new List<T> { handler });
                     }
                 }
             }
@@ -375,7 +392,9 @@ void StartClient()
                     Channel.BasicAck(@event.DeliveryTag, false);
 
                     if (@event.BasicProperties.Headers is null)
+                    {
                         @event.BasicProperties.Headers = new Dictionary<string, object>();
+                    }
 
                     var exchange = _exchanges.FirstOrDefault(x => x.Name == @event.Exchange);
                     if (exchange is null)
@@ -393,7 +412,9 @@ void StartClient()
                         _logger.LogInformation("The failed message has been requeued.");
                     }
                     else
+                    {
                         _logger.LogInformation("The failed message would not be requeued.");
+                    }
                 }
             };
 
@@ -462,10 +483,12 @@ void StartQueue(RabbitMqQueueOptions queue, string exchangeName)
             {
                 // If there are not any routing keys then make a bind with a queue name.
                 foreach (var route in queue.RoutingKeys)
+                {
                     _channel.QueueBind(
                         queue: queue.Name,
                         exchange: exchangeName,
                         routingKey: route);
+                }
             }
             else
             {
@@ -479,20 +502,28 @@ void StartQueue(RabbitMqQueueOptions queue, string exchangeName)
         void ValidateArguments(string exchangeName, string routingKey)
         {
             if (string.IsNullOrEmpty(exchangeName))
+            {
                 throw new ArgumentException($"Argument {nameof(exchangeName)} is null or empty.", nameof(exchangeName));
+            }
             if (string.IsNullOrEmpty(routingKey))
+            {
                 throw new ArgumentException($"Argument {nameof(routingKey)} is null or empty.", nameof(routingKey));
+            }
 
             var deadLetterExchanges = _exchanges.Select(x => x.Options.DeadLetterExchange).Distinct();
             if (!_exchanges.Any(x => x.Name == exchangeName) && !deadLetterExchanges.Any(x => x == exchangeName))
+            {
                 throw new ArgumentException($"Exchange {nameof(exchangeName)} has not been deaclared yet.", nameof(exchangeName));
+            }
         }
 
         string GetDeadLetterExchange(string exchangeName)
         {
             var exchange = _exchanges.FirstOrDefault(x => x.Name == exchangeName);
             if (string.IsNullOrEmpty(exchange.Options.DeadLetterExchange))
+            {
                 throw new ArgumentException($"Exchange {nameof(exchangeName)} has not been configured with a dead letter exchange.", nameof(exchangeName));
+            }
 
             return exchange.Options.DeadLetterExchange;
         }