rabbitmq · michaelklishin · Jun 24, 2015 · Jun 24, 2015 · Jun 24, 2015
diff --git a/dotnet-visual-studio/1_Receive/Program.cs b/dotnet-visual-studio/1_Receive/Program.cs
@@ -11,7 +11,7 @@ public static void Main()
         using( var connection = factory.CreateConnection() )
         using( var channel = connection.CreateModel() )
         {
-            channel.QueueDeclare( queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null);
+            channel.QueueDeclare( queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null );
 
             var consumer = new QueueingBasicConsumer( channel );
             channel.BasicConsume( queue: "hello", noAck: true, consumer: consumer );

diff --git a/dotnet-visual-studio/2_NewTask/Program.cs b/dotnet-visual-studio/2_NewTask/Program.cs
@@ -18,7 +18,7 @@ public static void Main( string[] args )
             var properties = channel.CreateBasicProperties();
             properties.SetPersistent( true );
 
-            channel.BasicPublish(exchange: "", routingKey: "task_queue", basicProperties: properties, body: body );
+            channel.BasicPublish( exchange: "", routingKey: "task_queue", basicProperties: properties, body: body );
             Console.WriteLine( " [x] Sent {0}", message );
         }
 

diff --git a/dotnet-visual-studio/5_EmitLogTopic/Program.cs b/dotnet-visual-studio/5_EmitLogTopic/Program.cs
@@ -16,7 +16,7 @@ public static void Main( string[] args )
             var routingKey = ( args.Length > 0 ) ? args[0] : "anonymous.info";
             var message = ( args.Length > 1 ) ? string.Join( " ", args.Skip( 1 ).ToArray() ) : "Hello World!";
             var body = Encoding.UTF8.GetBytes( message );
-            channel.BasicPublish( "topic_logs", routingKey, null, body );
+            channel.BasicPublish( exchange: "topic_logs", routingKey: routingKey, basicProperties: null, body: body );
             Console.WriteLine( " [x] Sent '{0}':'{1}'", routingKey, message );
         }
     }

diff --git a/dotnet/EmitLog.cs b/dotnet/EmitLog.cs
@@ -4,23 +4,26 @@
 
 class EmitLog
 {
-    public static void Main(string[] args)
+    public static void Main( string[] args )
     {
         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.ExchangeDeclare("logs", "fanout");
+            channel.ExchangeDeclare( exchange: "logs", type: "fanout" );
 
-            var message = GetMessage(args);
-            var body = Encoding.UTF8.GetBytes(message);
-            channel.BasicPublish("logs", "", null, body);
-            Console.WriteLine(" [x] Sent {0}", message);
+            var message = GetMessage( args );
+            var body = Encoding.UTF8.GetBytes( message );
+            channel.BasicPublish( exchange: "logs", routingKey: "", basicProperties: null, body: body );
+            Console.WriteLine( " [x] Sent {0}", message );
         }
+
+        Console.WriteLine( " Press [enter] to exit." );
+        Console.ReadLine();
     }
 
-    private static string GetMessage(string[] args)
+    private static string GetMessage( string[] args )
     {
-      return ((args.Length > 0) ? string.Join(" ", args) : "info: Hello World!");
+        return ( ( args.Length > 0 ) ? string.Join( " ", args ) : "info: Hello World!" );
     }
 }
diff --git a/dotnet/EmitLogDirect.cs b/dotnet/EmitLogDirect.cs
@@ -5,23 +5,22 @@
 
 class EmitLogDirect
 {
-    public static void Main(string[] args)
+    public static void Main( string[] args )
     {
         var factory = new ConnectionFactory() { HostName = "localhost" };
-        using (var connection = factory.CreateConnection())
+        using( var connection = factory.CreateConnection() )
+        using( var channel = connection.CreateModel() )
         {
-            using (var channel = connection.CreateModel())
-            {
-                channel.ExchangeDeclare("direct_logs", "direct");
+            channel.ExchangeDeclare( exchange: "direct_logs", type: "direct" );
 
-                var severity = (args.Length > 0) ? args[0] : "info";
-                var message = (args.Length > 1) ? string.Join(" ", args.Skip(1)
-                                                                                      .ToArray())
                                                                   : "Hello World!";
-                var body = Encoding.UTF8.GetBytes(message);
-                channel.BasicPublish("direct_logs", severity, null, body);
-                Console.WriteLine(" [x] Sent '{0}':'{1}'", severity, message);
-            }
+            var severity = ( args.Length > 0 ) ? args[0] : "info";
+            var message = ( args.Length > 1 ) ? string.Join( " ", args.Skip( 1 ).ToArray() ) : "Hello World!";
+            var body = Encoding.UTF8.GetBytes( message );
+            channel.BasicPublish( exchange: "direct_logs", routingKey: severity, basicProperties: null, body: body );
+            Console.WriteLine( " [x] Sent '{0}':'{1}'", severity, message );
         }
+
+        Console.WriteLine( " Press [enter] to exit." );
+        Console.ReadLine();
     }
 }
diff --git a/dotnet/EmitLogTopic.cs b/dotnet/EmitLogTopic.cs
@@ -5,23 +5,19 @@
 
 class EmitLogTopic
 {
-    public static void Main(string[] args)
+    public static void Main( string[] args )
     {
         var factory = new ConnectionFactory() { HostName = "localhost" };
-        using (var connection = factory.CreateConnection())
+        using( var connection = factory.CreateConnection() )
+        using( var channel = connection.CreateModel() )
         {
-            using (var channel = connection.CreateModel())
-            {
-                channel.ExchangeDeclare("topic_logs", "topic");
+            channel.ExchangeDeclare( exchange: "topic_logs", type: "topic" );
 
-                var routingKey = (args.Length > 0) ? args[0] : "anonymous.info";
-                var message = (args.Length > 1) ? string.Join(" ", args.Skip(1)
-                                                                                  .ToArray())
-                                                               : "Hello World!";
-                var body = Encoding.UTF8.GetBytes(message);
-                channel.BasicPublish("topic_logs", routingKey, null, body);
-                Console.WriteLine(" [x] Sent '{0}':'{1}'", routingKey, message);
-            }
+            var routingKey = ( args.Length > 0 ) ? args[0] : "anonymous.info";
+            var message = ( args.Length > 1 ) ? string.Join( " ", args.Skip( 1 ).ToArray() ) : "Hello World!";
+            var body = Encoding.UTF8.GetBytes( message );
+            channel.BasicPublish( exchange: "topic_logs", routingKey: routingKey, basicProperties: null, body: body );
+            Console.WriteLine( " [x] Sent '{0}':'{1}'", routingKey, message );
         }
     }
 }
diff --git a/dotnet/NewTask.cs b/dotnet/NewTask.cs
@@ -4,29 +4,30 @@
 
 class NewTask
 {
-    public static void Main(string[] args)
+    public static void Main( string[] args )
     {
         var factory = new ConnectionFactory() { HostName = "localhost" };
-        using (var connection = factory.CreateConnection())
+        using( var connection = factory.CreateConnection() )
+        using( var channel = connection.CreateModel() )
         {
-            using (var channel = connection.CreateModel())
-            {
-                channel.QueueDeclare("task_queue", true, false, false, null);
+            channel.QueueDeclare( queue: "task_queue", durable: true, exclusive: false, autoDelete: false, arguments: null );
 
-                var message = GetMessage(args);
-                var body = Encoding.UTF8.GetBytes(message);
+            var message = GetMessage( args );
+            var body = Encoding.UTF8.GetBytes( message );
 
-                var properties = channel.CreateBasicProperties();
-                properties.SetPersistent(true);
+            var properties = channel.CreateBasicProperties();
+            properties.SetPersistent( true );
 
-                channel.BasicPublish("", "task_queue", properties, body);
-                Console.WriteLine(" [x] Sent {0}", message);
-            }
+            channel.BasicPublish( exchange: "", routingKey: "task_queue", basicProperties: properties, body: body );
+            Console.WriteLine( " [x] Sent {0}", message );
         }
+
+        Console.WriteLine( " Press [enter] to exit." );
+        Console.ReadLine();
     }
 
-    private static string GetMessage(string[] args)
+    private static string GetMessage( string[] args )
     {
-      return ((args.Length > 0) ? string.Join(" ", args) : "Hello World!");
+        return ( ( args.Length > 0 ) ? string.Join( " ", args ) : "Hello World!" );
     }
 }
diff --git a/dotnet/RPCClient.cs b/dotnet/RPCClient.cs
@@ -1,7 +1,10 @@
 using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
 using RabbitMQ.Client;
 using RabbitMQ.Client.Events;
-using System.Text;
 
 class RPCClient
 {
@@ -16,26 +19,26 @@ public RPCClient()
         connection = factory.CreateConnection();
         channel = connection.CreateModel();
         replyQueueName = channel.QueueDeclare().QueueName;
-        consumer = new QueueingBasicConsumer(channel);
-        channel.BasicConsume(replyQueueName, true, 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("", "rpc_queue", props, 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 );
             }
         }
     }

diff --git a/dotnet/RPCServer.cs b/dotnet/RPCServer.cs
@@ -8,55 +8,58 @@ class RPCServer
     public static void Main()
     {
         var factory = new ConnectionFactory() { HostName = "localhost" };
-        using (var connection = factory.CreateConnection())
+        using( var connection = factory.CreateConnection() )
+        using( var channel = connection.CreateModel() )
         {
-            using (var channel = connection.CreateModel())
-            {
-                channel.QueueDeclare("rpc_queue", false, false, false, null);
-                channel.BasicQos(0, 1, false);
-                var consumer = new QueueingBasicConsumer(channel);
-                channel.BasicConsume("rpc_queue", false, 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)
-                {
-                    string response = null;
-                    var ea =
-                        (BasicDeliverEventArgs)consumer.Queue.Dequeue();
+            while( true )
+            {
+                string response = null;
+                var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
 
-                    var body = ea.Body;
-                    var props = ea.BasicProperties;
-                    var replyProps = channel.CreateBasicProperties();
-                    replyProps.CorrelationId = props.CorrelationId;
+                var body = ea.Body;
+                var props = ea.BasicProperties;
+                var replyProps = channel.CreateBasicProperties();
+                replyProps.CorrelationId = props.CorrelationId;
 
-                    try
-                    {
-                        var message = Encoding.UTF8.GetString(body);
-                        int n = int.Parse(message);
-                        Console.WriteLine(" [.] fib({0})", message);
-                        response = fib(n).ToString();
-                    }
-                    catch (Exception e)
-                    {
-                        Console.WriteLine(" [.] " + e.Message);
-                        response = "";
-                    }
-                    finally
-                    {
-                        var responseBytes =
-                            Encoding.UTF8.GetBytes(response);
-                        channel.BasicPublish("", props.ReplyTo, replyProps,
-                                             responseBytes);
-                        channel.BasicAck(ea.DeliveryTag, false);
-                    }
+                try
+                {
+                    var message = Encoding.UTF8.GetString( body );
+                    int n = int.Parse( message );
+                    Console.WriteLine( " [.] fib({0})", message );
+                    response = fib( n ).ToString();
+                }
+                catch( Exception e )
+                {
+                    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 );
                 }
             }
         }
     }
 
-    private static int fib(int n)
+    /// <summary>
+    /// 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 )
     {
-        if (n == 0 || n == 1) return n;
-        return fib(n - 1) + fib(n - 2);
+        if( n == 0 || n == 1 )
+        {
+            return n;
+        }
+
+        return fib( n - 1 ) + fib( n - 2 );
     }
 }
diff --git a/dotnet/Receive.cs b/dotnet/Receive.cs
@@ -8,25 +8,22 @@ class Receive
     public static void Main()
     {
         var factory = new ConnectionFactory() { HostName = "localhost" };
-        using (var connection = factory.CreateConnection())
+        using( var connection = factory.CreateConnection() )
+        using( var channel = connection.CreateModel() )
         {
-            using (var channel = connection.CreateModel())
-            {
-                channel.QueueDeclare("hello", false, false, false, null);
+            channel.QueueDeclare( queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null );
 
-                var consumer = new QueueingBasicConsumer(channel);
-                channel.BasicConsume("hello", true, consumer);
+            var consumer = new QueueingBasicConsumer( channel );
+            channel.BasicConsume( queue: "hello", noAck: true, consumer: consumer );
 
-                Console.WriteLine(" [*] Waiting for messages." +
-                                         "To exit press CTRL+C");
-                while (true)
-                {
-                    var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
+            Console.WriteLine( " [*] Waiting for messages. To exit press CTRL+C" );
+            while( true )
+            {
+                var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
 
-                    var body = ea.Body;
-                    var message = Encoding.UTF8.GetString(body);
-                    Console.WriteLine(" [x] Received {0}", message);
-                }
+                var body = ea.Body;
+                var message = Encoding.UTF8.GetString( body );
+                Console.WriteLine( " [x] Received {0}", message );
             }
         }
     }