Reformatted and cleaned up

Author: keithelder

dotnet/ReceiveLogsDirect.cs

@@ -2,42 +2,47 @@
 using RabbitMQ.Client;
 using RabbitMQ.Client.Events;
 
-class ReceiveLogsDirect {
-    public static void Main(string[] args) {
-        ConnectionFactory factory = new ConnectionFactory();
-        factory.HostName = "localhost";
-        using (IConnection connection = factory.CreateConnection())
-        using (IModel channel = connection.CreateModel()) {
-
-            channel.ExchangeDeclare("direct_logs", "direct");
-            string queue_name = channel.QueueDeclare();
-
-            if (args.Length < 1) {
-                Console.Error.WriteLine("Usage: {0} [info] [warning] [error]",
-                                        Environment.GetCommandLineArgs()[0]);
-                Environment.ExitCode = 1;
-                return;
-            }
-
-            foreach (string severity in args) {
-                channel.QueueBind(queue_name, "direct_logs", severity);
-            }
-
-            Console.WriteLine(" [*] Waiting for messages. " +
-                              "To exit press CTRL+C");
-
-            QueueingBasicConsumer consumer = new QueueingBasicConsumer(channel);
-            channel.BasicConsume(queue_name, true, consumer);
-
-            while(true) {
-                BasicDeliverEventArgs ea =
-                    (BasicDeliverEventArgs)consumer.Queue.Dequeue();
-
-                byte[] body = ea.Body;
-                string message = System.Text.Encoding.UTF8.GetString(body);
-                string routingKey = ea.RoutingKey;
-                Console.WriteLine(" [x] Received '{0}':'{1}'",
-                                  routingKey, message);
+class ReceiveLogsDirect
+{
+    public static void Main(string[] args)
+    {
+        var factory = new ConnectionFactory() { HostName = "localhost" };
+        using (var connection = factory.CreateConnection())
+        {
+            using (var channel = connection.CreateModel())
+            {
+                channel.ExchangeDeclare("direct_logs", "direct");
+                var queue_name = channel.QueueDeclare();
+
+                if (args.Length < 1)
+                {
+                    Console.Error.WriteLine("Usage: {0} [info] [warning] [error]",
+                                            Environment.GetCommandLineArgs()[0]);
+                    Environment.ExitCode = 1;
+                    return;
+                }
+
+                foreach (string severity in args)
+                {
+                    channel.QueueBind(queue_name, "direct_logs", severity);
+                }
+
+                Console.WriteLine(" [*] Waiting for messages. " +
+                                  "To exit press CTRL+C");
+
+                var consumer = new QueueingBasicConsumer(channel);
+                channel.BasicConsume(queue_name, true, consumer);
+
+                while (true)
+                {
+                    var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
+
+                    var body = ea.Body;
+                    var message = System.Text.Encoding.UTF8.GetString(body);
+                    var routingKey = ea.RoutingKey;
+                    Console.WriteLine(" [x] Received '{0}':'{1}'",
+                                      routingKey, message);
+                }
             }
         }
     }