Reformatted and cleaned up

Author: keithelder

dotnet/ReceiveLogsTopic.cs

@@ -1,43 +1,48 @@
 using System;
 using RabbitMQ.Client;
 using RabbitMQ.Client.Events;
+using System.Text;
 
-class ReceiveLogsTopic {
-    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("topic_logs", "topic");
-            string queue_name = channel.QueueDeclare();
+class ReceiveLogsTopic
+{
+    public static void Main(string[] args)
+    {
+        var factory = new ConnectionFactory() { HostName = "localhost" };
+        using (var connection = factory.CreateConnection())
+        {
+            using (var channel = connection.CreateModel())
+            {
+                channel.ExchangeDeclare("topic_logs", "topic");
+                var queueName = channel.QueueDeclare();
 
-            if (args.Length < 1) {
-                Console.Error.WriteLine("Usage: {0} [binding_key...]",
-                                        Environment.GetCommandLineArgs()[0]);
-                Environment.ExitCode = 1;
-                return;
-            }
-
-            foreach (string bindingKey in args) {
-                channel.QueueBind(queue_name, "topic_logs", bindingKey);
-            }
+                if (args.Length < 1)
+                {
+                    Console.Error.WriteLine("Usage: {0} [binding_key...]",
+                                            Environment.GetCommandLineArgs()[0]);
+                    Environment.ExitCode = 1;
+                    return;
+                }
 
-            Console.WriteLine(" [*] Waiting for messages. " +
-                              "To exit press CTRL+C");
+                foreach (var bindingKey in args)
+                {
+                    channel.QueueBind(queueName, "topic_logs", bindingKey);
+                }
 
-            QueueingBasicConsumer consumer =
-                new QueueingBasicConsumer(channel);
-            channel.BasicConsume(queue_name, true, consumer);
+                Console.WriteLine(" [*] Waiting for messages. " +
+                                  "To exit press CTRL+C");
 
-            while(true) {
-                BasicDeliverEventArgs ea =
-                    (BasicDeliverEventArgs)consumer.Queue.Dequeue();
+                var consumer = new QueueingBasicConsumer(channel);
+                channel.BasicConsume(queueName, true, consumer);
 
-                byte[] body = ea.Body;
-                string message = System.Text.Encoding.UTF8.GetString(body);
-                string routingKey = ea.RoutingKey;
-                Console.WriteLine(" [x] Received '{0}':'{1}'",
-                                  routingKey, message);
+                while (true)
+                {
+                    var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
+                    var body = ea.Body;
+                    var message = Encoding.UTF8.GetString(body);
+                    var routingKey = ea.RoutingKey;
+                    Console.WriteLine(" [x] Received '{0}':'{1}'",
+                                      routingKey, message);
+                }
             }
         }
     }