8000 Adhere to the existing coding style · syk-coder/rabbitmq-tutorials@6704d45 · GitHub
[go: up one dir, main page]
Skip to content

Commit 6704d45

Browse files
michaelklishinmichaelklishin
committed
Adhere to the existing coding style
1 parent cf2a783 commit 6704d45

File tree

2 files changed

+28
-28
lines changed

2 files changed

+28
-28
lines changed

‎dotnet/RPCClient.cs

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -19,26 +19,26 @@ public RPCClient()
1919
connection = factory.CreateConnection();
2020
channel = connection.CreateModel();
2121
replyQueueName = channel.QueueDeclare().QueueName;
22-
consumer = new QueueingBasicConsumer( channel );
23-
channel.BasicConsume( queue: replyQueueName, noAck: true, consumer: consumer );
22+
consumer = new QueueingBasicConsumer(channel);
23+
channel.BasicConsume(queue: replyQueueName, noAck: true, consumer: consumer);
2424
}
2525

26-
public string Call( string message )
26+
public string Call(string message)
2727
{
2828
var corrId = Guid.NewGuid().ToString();
2929
var props = channel.CreateBasicProperties();
3030
props.ReplyTo = replyQueueName;
3131
props.CorrelationId = corrId;
3232

33-
var messageBytes = Encoding.UTF8.GetBytes( message );
34-
channel.BasicPublish( exchange: "", routingKey: "rpc_queue", basicProperties: props, body: messageBytes );
33+
var messageBytes = Encoding.UTF8.GetBytes(message);
34+
channel.BasicPublish(exchange: "", routingKey: "rpc_queue", basicProperties: props, body: messageBytes);
3535

36-
while( true )
36+
while(true)
3737
{
3838
var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
39-
if( ea.BasicProperties.CorrelationId == corrId )
39+
if(ea.BasicProperties.CorrelationId == corrId)
4040
{
41-
return Encoding.UTF8.GetString( ea.Body );
41+
return Encoding.UTF8.GetString(ea.Body);
4242
}
4343
}
4444
}

‎dotnet/RPCServer.cs

Lines changed: 20 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -8,16 +8,16 @@ class RPCServer
88
public static void Main()
99
{
1010
var factory = new ConnectionFactory() { HostName = "localhost" };
11-
using( var connection = factory.CreateConnection() )
12-
using( var channel = connection.CreateModel() )
11+
using(var connection = factory.CreateConnection())
12+
using(var channel = connection.CreateModel())
1313
{
14-
channel.QueueDeclare( queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null );
15-
channel.BasicQos( 0, 1, false );
16-
var consumer = new QueueingBasicConsumer( channel );
17-
channel.BasicConsume( queue: "rpc_queue", noAck: false, consumer: consumer );
18-
Console.WriteLine( " [x] Awaiting RPC requests" );
14+
channel.QueueDeclare(queue: "rpc_queue", durable: false, exclusive: false, autoDelete: false, arguments: null);
15+
channel.BasicQos(0, 1, false);
16+
var consumer = new QueueingBasicConsumer(channel);
17+
channel.BasicConsume(queue: "rpc_queue", noAck: false, consumer: consumer);
18+
Console.WriteLine(" [x] Awaiting RPC requests");
1919

20-
while( true )
20+
while(true)
2121
{
2222
string response = null;
2323
var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
@@ -29,21 +29,21 @@ public static void Main()
2929

3030
try
3131
{
32-
var message = Encoding.UTF8.GetString( body );
33-
int n = int.Parse( message );
34-
Console.WriteLine( " [.] fib({0})", message );
35-
response = fib( n ).ToString();
32+
var message = Encoding.UTF8.GetString(body);
33+
int n = int.Parse(message);
34+
Console.WriteLine(" [.] fib({0})", message);
35+
response = fib(n).ToString();
3636
}
37-
catch( Exception e )
37+
catch(Exception e)
3838
{
39-
Console.WriteLine( " [.] " + e.Message );
39+
Console.WriteLine(" [.] " + e.Message);
4040
response = "";
4141
}
4242
finally
4343
{
44-
var responseBytes = Encoding.UTF8.GetBytes( response );
45-
channel.BasicPublish( exchange: "", routingKey: props.ReplyTo, basicProperties: replyProps, body: responseBytes );
46-
channel.BasicAck( deliveryTag: ea.DeliveryTag, multiple: false );
44+
var responseBytes = Encoding.UTF8.GetBytes(response);
45+
channel.BasicPublish(exchange: "", routingKey: props.ReplyTo, basicProperties: replyProps, body: responseBytes);
46+
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: false);
4747
}
4848
}
4949
}
@@ -53,13 +53,13 @@ public static void Main()
5353
/// Assumes only valid positive integer input.
5454
/// Don't expect this one to work for big numbers, and it's probably the slowest recursive implementation possible.
5555
/// </summary>
56-
private static int fib( int n )
56+
private static int fib(int n)
5757
{
58-
if( n == 0 || n == 1 )
58+
if(n == 0 || n == 1)
5959
{
6060
return n;
6161
}
6262

63-
return fib( n - 1 ) + fib( n - 2 );
63+
return fib(n - 1) + fib(n - 2);
6464
}
6565
}

0 commit comments

Comments
 (0)
0