Adhere to the existing coding style

Author: michaelklishin

dotnet/RPCClient.cs

@@ -19,26 +19,26 @@ public RPCClient()
         connection = factory.CreateConnection();
         channel = connection.CreateModel();
         replyQueueName = channel.QueueDeclare().QueueName;
-        consumer = new QueueingBasicConsumer( channel );
-        channel.BasicConsume( queue: replyQueueName, noAck: true, consumer: consumer );
+        consumer = new QueueingBasicConsumer(channel);
+        channel.BasicConsume(queue: replyQueueName, noAck: true, consumer: consumer);
     }
 
-    public string Call( string message )
+    public string Call(string message)
     {
         var corrId = Guid.NewGuid().ToString();
         var props = channel.CreateBasicProperties();
         props.ReplyTo = replyQueueName;
         props.CorrelationId = corrId;
 
-        var messageBytes = Encoding.UTF8.GetBytes( message );
-        channel.BasicPublish( exchange: "", routingKey: "rpc_queue", basicProperties: props, body: messageBytes );
+        var messageBytes = Encoding.UTF8.GetBytes(message);
+        channel.BasicPublish(exchange: "", routingKey: "rpc_queue", basicProperties: props, body: messageBytes);
 
-        while( true )
+        while(true)
         {
             var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
-            if( ea.BasicProperties.CorrelationId == corrId )
+            if(ea.BasicProperties.CorrelationId == corrId)
             {
-                return Encoding.UTF8.GetString( ea.Body );
+                return Encoding.UTF8.GetString(ea.Body);
             }
         }
     }

dotnet/RPCServer.cs

@@ -8,16 +8,16 @@ class RPCServer
     public static void Main()
     {
         var factory = new ConnectionFactory() { HostName = "localhost" };
-        using( var connection = factory.CreateConnection() )
-        using( var channel = connection.CreateModel() )
+        using(var connection = factory.CreateConnection())
+        using(var channel = connection.CreateModel())
         {
-            channel.QueueDeclare( queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null );
-            channel.BasicQos( 0, 1, false );
-            var consumer = new QueueingBasicConsumer( channel );
-            channel.BasicConsume( queue: "rpc_queue", noAck: false, consumer: consumer );
-            Console.WriteLine( " [x] Awaiting RPC requests" );
+            channel.QueueDeclare(queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null);
+            channel.BasicQos(0, 1, false);
+            var consumer = new QueueingBasicConsumer(channel);
+            channel.BasicConsume(queue: "rpc_queue", noAck: false, consumer: consumer);
+            Console.WriteLine(" [x] Awaiting RPC requests");
 
-            while( true )
+            while(true)
             {
                 string response = null;
                 var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
@@ -29,21 +29,21 @@ public static void Main()
 
                 try
                 {
-                    var message = Encoding.UTF8.GetString( body );
-                    int n = int.Parse( message );
-                    Console.WriteLine( " [.] fib({0})", message );
-                    response = fib( n ).ToString();
+                    var message = Encoding.UTF8.GetString(body);
+                    int n = int.Parse(message);
+                    Console.WriteLine(" [.] fib({0})", message);
+                    response = fib(n).ToString();
                 }
-                catch( Exception e )
+                catch(Exception e)
                 {
-                    Console.WriteLine( " [.] " + e.Message );
+                    Console.WriteLine(" [.] " + e.Message);
                     response = "";
                 }
                 finally
                 {
-                    var responseBytes = Encoding.UTF8.GetBytes( response );
-                    channel.BasicPublish( exchange: "", routingKey: props.ReplyTo, basicProperties: replyProps, body: responseBytes );
-                    channel.BasicAck( deliveryTag: ea.DeliveryTag, multiple: false );
+                    var responseBytes = Encoding.UTF8.GetBytes(response);
+                    channel.BasicPublish(exchange: "", routingKey: props.ReplyTo, basicProperties: replyProps, body: responseBytes);
+                    channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
                 }
             }
         }
@@ -53,13 +53,13 @@ public static void Main()
     /// Assumes only valid positive integer input.
     /// Don't expect this one to work for big numbers, and it's probably the slowest recursive implementation possible.
     /// </summary>
-    private static int fib( int n )
+    private static int fib(int n)
     {
-        if( n == 0 || n == 1 )
+        if(n == 0 || n == 1)
         {
             return n;
         }
 
-        return fib( n - 1 ) + fib( n - 2 );
+        return fib(n - 1) + fib(n - 2);
     }
 }