Merge pull request rabbitmq#57 from Pliner/master

michaelklishin · michaelklishin · commit f28357278958 · 2015-06-24T22:43:22.000+03:00
Named parameter version of the API rabbitmq#20
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 );
             }
         }
     }
diff --git a/dotnet/ReceiveLogs.cs b/dotnet/ReceiveLogs.cs
diff --git a/dotnet/ReceiveLogsDirect.cs b/dotnet/ReceiveLogsDirect.cs
diff --git a/dotnet/ReceiveLogsTopic.cs b/dotnet/ReceiveLogsTopic.cs
diff --git a/dotnet/Send.cs b/dotnet/Send.cs
diff --git a/dotnet/Worker.cs b/dotnet/Worker.cs

Original file line number	Diff line number	Diff line change
`@@ -11,7 +11,7 @@ public static void Main()`
`11`	`11`	`using( var connection = factory.CreateConnection() )`
`12`	`12`	`using( var channel = connection.CreateModel() )`
`13`	`13`	`{`
`14`		`- channel.QueueDeclare( queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null);`
	`14`	`+ channel.QueueDeclare( queue: "hello", durable: false, exclusive: false, autoDelete: false, arguments: null );`
`15`	`15`
`16`	`16`	`var consumer = new QueueingBasicConsumer( channel );`
`17`	`17`	`channel.BasicConsume( queue: "hello", noAck: true, consumer: consumer );`
Original file line number	Diff line number	Diff line change
`@@ -18,7 +18,7 @@ public static void Main( string[] args )`
`18`	`18`	`var properties = channel.CreateBasicProperties();`
`19`	`19`	`properties.SetPersistent( true );`
`20`	`20`
`21`		`- channel.BasicPublish(exchange: "", routingKey: "task_queue", basicProperties: properties, body: body );`
	`21`	`+ channel.BasicPublish( exchange: "", routingKey: "task_queue", basicProperties: properties, body: body );`
`22`	`22`	`Console.WriteLine( " [x] Sent {0}", message );`
`23`	`23`	`}`
`24`	`24`
Original file line number	Diff line number	Diff line change
`@@ -16,7 +16,7 @@ public static void Main( string[] args )`
`16`	`16`	`var routingKey = ( args.Length > 0 ) ? args[0] : "anonymous.info";`
`17`	`17`	`var message = ( args.Length > 1 ) ? string.Join( " ", args.Skip( 1 ).ToArray() ) : "Hello World!";`
`18`	`18`	`var body = Encoding.UTF8.GetBytes( message );`
`19`		`- channel.BasicPublish( "topic_logs", routingKey, null, body );`
	`19`	`+ channel.BasicPublish( exchange: "topic_logs", routingKey: routingKey, basicProperties: null, body: body );`
`20`	`20`	`Console.WriteLine( " [x] Sent '{0}':'{1}'", routingKey, message );`
`21`	`21`	`}`
`22`	`22`	`}`
Original file line number	Diff line number	Diff line change
`@@ -4,23 +4,26 @@`
`4`	`4`
`5`	`5`	`class EmitLog`
`6`	`6`	`{`
`7`		`- public static void Main(string[] args)`
	`7`	`+ public static void Main( string[] args )`
`8`	`8`	`{`
`9`	`9`	`var factory = new ConnectionFactory() { HostName = "localhost" };`
`10`		`- using (var connection = factory.CreateConnection())`
`11`		`- using (var channel = connection.CreateModel())`
	`10`	`+ using( var connection = factory.CreateConnection() )`
	`11`	`+ using( var channel = connection.CreateModel() )`
`12`	`12`	`{`
`13`		`- channel.ExchangeDeclare("logs", "fanout");`
	`13`	`+ channel.ExchangeDeclare( exchange: "logs", type: "fanout" );`
`14`	`14`
`15`		`- var message = GetMessage(args);`
`16`		`- var body = Encoding.UTF8.GetBytes(message);`
`17`		`- channel.BasicPublish("logs", "", null, body);`
`18`		`- Console.WriteLine(" [x] Sent {0}", message);`
	`15`	`+ var message = GetMessage( args );`
	`16`	`+ var body = Encoding.UTF8.GetBytes( message );`
	`17`	`+ channel.BasicPublish( exchange: "logs", routingKey: "", basicProperties: null, body: body );`
	`18`	`+ Console.WriteLine( " [x] Sent {0}", message );`
`19`	`19`	`}`
	`20`	`+`
	`21`	`+ Console.WriteLine( " Press [enter] to exit." );`
	`22`	`+ Console.ReadLine();`
`20`	`23`	`}`
`21`	`24`
`22`		`- private static string GetMessage(string[] args)`
	`25`	`+ private static string GetMessage( string[] args )`
`23`	`26`	`{`
`24`		`- return ((args.Length > 0) ? string.Join(" ", args) : "info: Hello World!");`
	`27`	`+ return ( ( args.Length > 0 ) ? string.Join( " ", args ) : "info: Hello World!" );`
`25`	`28`	`}`
`26`	`29`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,23 +5,22 @@`
`5`	`5`
`6`	`6`	`class EmitLogDirect`
`7`	`7`	`{`
`8`		`- public static void Main(string[] args)`
	`8`	`+ public static void Main( string[] args )`
`9`	`9`	`{`
`10`	`10`	`var factory = new ConnectionFactory() { HostName = "localhost" };`
`11`		`- using (var connection = factory.CreateConnection())`
	`11`	`+ using( var connection = factory.CreateConnection() )`
	`12`	`+ using( var channel = connection.CreateModel() )`
`12`	`13`	`{`
`13`		`- using (var channel = connection.CreateModel())`
`14`		`- {`
`15`		`- channel.ExchangeDeclare("direct_logs", "direct");`
	`14`	`+ channel.ExchangeDeclare( exchange: "direct_logs", type: "direct" );`
`16`	`15`
`17`		`- var severity = (args.Length > 0) ? args[0] : "info";`
`18`		`- var message = (args.Length > 1) ? string.Join(" ", args.Skip(1)`
`19`		`- .ToArray())`
`20`		`- : "Hello World!";`
`21`		`- var body = Encoding.UTF8.GetBytes(message);`
`22`		`- channel.BasicPublish("direct_logs", severity, null, body);`
`23`		`- Console.WriteLine(" [x] Sent '{0}':'{1}'", severity, message);`
`24`		`- }`
	`16`	`+ var severity = ( args.Length > 0 ) ? args[0] : "info";`
	`17`	`+ var message = ( args.Length > 1 ) ? string.Join( " ", args.Skip( 1 ).ToArray() ) : "Hello World!";`
	`18`	`+ var body = Encoding.UTF8.GetBytes( message );`
	`19`	`+ channel.BasicPublish( exchange: "direct_logs", routingKey: severity, basicProperties: null, body: body );`
	`20`	`+ Console.WriteLine( " [x] Sent '{0}':'{1}'", severity, message );`
`25`	`21`	`}`
	`22`	`+`
	`23`	`+ Console.WriteLine( " Press [enter] to exit." );`
	`24`	`+ Console.ReadLine();`
`26`	`25`	`}`
`27`	`26`	`}`
Original file line number	Diff line number	Diff line change
`@@ -5,23 +5,19 @@`
`5`	`5`
`6`	`6`	`class EmitLogTopic`
`7`	`7`	`{`
`8`		`- public static void Main(string[] args)`
	`8`	`+ public static void Main( string[] args )`
`9`	`9`	`{`
`10`	`10`	`var factory = new ConnectionFactory() { HostName = "localhost" };`
`11`		`- using (var connection = factory.CreateConnection())`
	`11`	`+ using( var connection = factory.CreateConnection() )`
	`12`	`+ using( var channel = connection.CreateModel() )`
`12`	`13`	`{`
`13`		`- using (var channel = connection.CreateModel())`
`14`		`- {`
`15`		`- channel.ExchangeDeclare("topic_logs", "topic");`
	`14`	`+ channel.ExchangeDeclare( exchange: "topic_logs", type: "topic" );`
`16`	`15`
`17`		`- var routingKey = (args.Length > 0) ? args[0] : "anonymous.info";`
`18`		`- var message = (args.Length > 1) ? string.Join(" ", args.Skip(1)`
`19`		`- .ToArray())`
`20`		`- : "Hello World!";`
`21`		`- var body = Encoding.UTF8.GetBytes(message);`
`22`		`- channel.BasicPublish("topic_logs", routingKey, null, body);`
`23`		`- Console.WriteLine(" [x] Sent '{0}':'{1}'", routingKey, message);`
`24`		`- }`
	`16`	`+ var routingKey = ( args.Length > 0 ) ? args[0] : "anonymous.info";`
	`17`	`+ var message = ( args.Length > 1 ) ? string.Join( " ", args.Skip( 1 ).ToArray() ) : "Hello World!";`
	`18`	`+ var body = Encoding.UTF8.GetBytes( message );`
	`19`	`+ channel.BasicPublish( exchange: "topic_logs", routingKey: routingKey, basicProperties: null, body: body );`
	`20`	`+ Console.WriteLine( " [x] Sent '{0}':'{1}'", routingKey, message );`
`25`	`21`	`}`
`26`	`22`	`}`
`27`	`23`	`}`
Original file line number	Diff line number	Diff line change
`@@ -4,29 +4,30 @@`
`4`	`4`
`5`	`5`	`class NewTask`
`6`	`6`	`{`
`7`		`- public static void Main(string[] args)`
	`7`	`+ public static void Main( string[] args )`
`8`	`8`	`{`
`9`	`9`	`var factory = new ConnectionFactory() { HostName = "localhost" };`
`10`		`- using (var connection = factory.CreateConnection())`
	`10`	`+ using( var connection = factory.CreateConnection() )`
	`11`	`+ using( var channel = connection.CreateModel() )`
`11`	`12`	`{`
`12`		`- using (var channel = connection.CreateModel())`
`13`		`- {`
`14`		`- channel.QueueDeclare("task_queue", true, false, false, null);`
	`13`	`+ channel.QueueDeclare( queue: "task_queue", durable: true, exclusive: false, autoDelete: false, arguments: null );`
`15`	`14`
`16`		`- var message = GetMessage(args);`
`17`		`- var body = Encoding.UTF8.GetBytes(message);`
	`15`	`+ var message = GetMessage( args );`
	`16`	`+ var body = Encoding.UTF8.GetBytes( message );`
`18`	`17`
`19`		`- var properties = channel.CreateBasicProperties();`
`20`		`- properties.SetPersistent(true);`
	`18`	`+ var properties = channel.CreateBasicProperties();`
	`19`	`+ properties.SetPersistent( true );`
`21`	`20`
`22`		`- channel.BasicPublish("", "task_queue", properties, body);`
`23`		`- Console.WriteLine(" [x] Sent {0}", message);`
`24`		`- }`
	`21`	`+ channel.BasicPublish( exchange: "", routingKey: "task_queue", basicProperties: properties, body: body );`
	`22`	`+ Console.WriteLine( " [x] Sent {0}", message );`
`25`	`23`	`}`
	`24`	`+`
	`25`	`+ Console.WriteLine( " Press [enter] to exit." );`
	`26`	`+ Console.ReadLine();`
`26`	`27`	`}`
`27`	`28`
`28`		`- private static string GetMessage(string[] args)`
	`29`	`+ private static string GetMessage( string[] args )`
`29`	`30`	`{`
`30`		`- return ((args.Length > 0) ? string.Join(" ", args) : "Hello World!");`
	`31`	`+ return ( ( args.Length > 0 ) ? string.Join( " ", args ) : "Hello World!" );`
`31`	`32`	`}`
`32`	`33`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,10 @@`
`1`	`1`	`using System;`
	`2`	`+using System.Collections.Generic;`
	`3`	`+using System.Linq;`
	`4`	`+using System.Text;`
	`5`	`+using System.Threading.Tasks;`
`2`	`6`	`using RabbitMQ.Client;`
`3`	`7`	`using RabbitMQ.Client.Events;`
`4`		`-using System.Text;`
`5`	`8`
`6`	`9`	`class RPCClient`
`7`	`10`	`{`
`@@ -16,26 +19,26 @@ public RPCClient()`
`16`	`19`	`connection = factory.CreateConnection();`
`17`	`20`	`channel = connection.CreateModel();`
`18`	`21`	`replyQueueName = channel.QueueDeclare().QueueName;`
`19`		`- consumer = new QueueingBasicConsumer(channel);`
`20`		`- channel.BasicConsume(replyQueueName, true, consumer);`
	`22`	`+ consumer = new QueueingBasicConsumer( channel );`
	`23`	`+ channel.BasicConsume( queue: replyQueueName, noAck: true, consumer: consumer );`
`21`	`24`	`}`
`22`	`25`
`23`		`- public string Call(string message)`
	`26`	`+ public string Call( string message )`
`24`	`27`	`{`
`25`	`28`	`var corrId = Guid.NewGuid().ToString();`
`26`	`29`	`var props = channel.CreateBasicProperties();`
`27`	`30`	`props.ReplyTo = replyQueueName;`
`28`	`31`	`props.CorrelationId = corrId;`
`29`	`32`
`30`		`- var messageBytes = Encoding.UTF8.GetBytes(message);`
`31`		`- channel.BasicPublish("", "rpc_queue", props, messageBytes);`
	`33`	`+ var messageBytes = Encoding.UTF8.GetBytes( message );`
	`34`	`+ channel.BasicPublish( exchange: "", routingKey: "rpc_queue", basicProperties: props, body: messageBytes );`
`32`	`35`
`33`		`- while (true)`
	`36`	`+ while( true )`
`34`	`37`	`{`
`35`	`38`	`var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();`
`36`		`- if (ea.BasicProperties.CorrelationId == corrId)`
	`39`	`+ if( ea.BasicProperties.CorrelationId == corrId )`
`37`	`40`	`{`
`38`		`- return Encoding.UTF8.GetString(ea.Body);`
	`41`	`+ return Encoding.UTF8.GetString( ea.Body );`
`39`	`42`	`}`
`40`	`43`	`}`
`41`	`44`	`}`