From cf2a7838e0fc3cb3ea0ca620c7f9a801b350ebf2 Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Wed, 29 Jul 2015 13:23:06 +0300 Subject: [PATCH 1/2] Update for Mono 4.0 --- dotnet/recompile.sh | 5 +++++ 1 file changed, 5 insertions(+) create mode 100755 dotnet/recompile.sh diff --git a/dotnet/recompile.sh b/dotnet/recompile.sh new file mode 100755 index 00000000..71d74c96 --- /dev/null +++ b/dotnet/recompile.sh @@ -0,0 +1,5 @@ +#!/bin/sh + +for f in *.cs; do \ + mcs -r:lib/bin/RabbitMQ.Client.dll $f; \ +done From 6704d454e400caf7194441a108e7832257e6815d Mon Sep 17 00:00:00 2001 From: Michael Klishin Date: Wed, 29 Jul 2015 13:49:34 +0300 Subject: [PATCH 2/2] Adhere to the existing coding style --- dotnet/RPCClient.cs | 16 ++++++++-------- dotnet/RPCServer.cs | 40 ++++++++++++++++++++-------------------- 2 files changed, 28 insertions(+), 28 deletions(-) diff --git a/dotnet/RPCClient.cs b/dotnet/RPCClient.cs index 1a800912..1c7159d6 100644 --- a/dotnet/RPCClient.cs +++ b/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); } } } diff --git a/dotnet/RPCServer.cs b/dotnet/RPCServer.cs index fccc62f6..2075ebb4 100644 --- a/dotnet/RPCServer.cs +++ b/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. /// - 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); } }