Reformatted and cleaned up

This commit is contained in:
Keith Elder 2013-08-24 22:27:21 -05:00
parent 5e94632260
commit ec652bf9c6

View File

@ -14,11 +14,11 @@ public static void Main()
{ {
channel.ExchangeDeclare("logs", "fanout"); channel.ExchangeDeclare("logs", "fanout");
var queue_name = channel.QueueDeclare(); var queueName = channel.QueueDeclare();
channel.QueueBind(queue_name, "logs", ""); channel.QueueBind(queueName, "logs", "");
var consumer = new QueueingBasicConsumer(channel); var consumer = new QueueingBasicConsumer(channel);
channel.BasicConsume(queue_name, true, consumer); channel.BasicConsume(queueName, true, consumer);
Console.WriteLine(" [*] Waiting for logs." + Console.WriteLine(" [*] Waiting for logs." +
"To exit press CTRL+C"); "To exit press CTRL+C");