using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Consumer1
{
    class Program
    {
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory()
            {
                UserName = "amivnqqc",
                VirtualHost = "amivnqqc",
                HostName = "bulldog.rmq.cloudamqp.com",
                Password = "WyPz_1Vl1KoR3lUvzgZfm7IhWXWYdnlE"
            };

            using (var connection = factory.CreateConnection())
            using (var channel = connection.CreateModel())
            {
                channel.QueueDeclare("ksr_queue", false, false, false, null);

                var consumer = new EventingBasicConsumer(channel);
                consumer.Received += (model, ea) =>
                {
                    var body = ea.Body;
                    var message = Encoding.UTF8.GetString(body);
                    Console.WriteLine("Message: '{0}'", message);

                    var responseBytes = Encoding.UTF8.GetBytes(DateTime.Now.ToLongTimeString());
                    var replyProps = channel.CreateBasicProperties();
                    replyProps.CorrelationId = ea.BasicProperties.CorrelationId;

                    channel.BasicPublish("", ea.BasicProperties.ReplyTo, replyProps, responseBytes);

                    channel.BasicAck(ea.DeliveryTag, false);
                };
                channel.BasicConsume("ksr_queue", false, consumer);

                Console.ReadKey();
            }
        }
    }
}