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


namespace ConsoleApp5
{
    class Program
    {
        class MyConsumer : DefaultBasicConsumer
        {
            public MyConsumer(IModel model) : base(model) { }
            public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool
           redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)
            {
                var message = Encoding.UTF8.GetString(body);
                // show message
            }
            private static void Receiv(object model, BasicDeliverEventArgs ea)
            {
                var body = ea.Body;
                var message = Encoding.UTF8.GetString(body);
                Console.WriteLine(" [x] Received:'{0}'", message, ConsoleColor.Yellow);
            }

        }
        static void Main(string[] args)
        {
            // host: https://api.cloudamqp.com/console/dd005f1a-f7de-408c-a2a6-3f3bdd8acfa8/details
            /*
            var factory = new ConnectionFactory()
            {
                UserName = "dahjdrhx",
                Password = "ng-DairYiYJDTY9JyemWFB9By5WqxXcA",
                HostName = "eagle.rmq.cloudamqp.com",
                VirtualHost = "dahjdrhx"
            };
            */
            // client http://localhost:15672/#/vhosts

            Thread.Sleep(1000);


            var factory = new ConnectionFactory()
            {
                UserName = "dahjdrhx",
                Password = "ng-DairYiYJDTY9JyemWFB9By5WqxXcA",
                HostName = "eagle.rmq.cloudamqp.com",
                VirtualHost = "dahjdrhx"
            };

            var connection = factory.CreateConnection();
            var channel = connection.CreateModel();
            channel.QueueDeclare("message_queue", true, false, false, null);
            var consumer = new EventingBasicConsumer(channel);

            // ZAD 2
            channel.BasicQos(0, 1, false);
            channel.BasicQos(0, 1, true);

            for (int i = 0; i < 50; i++) {
                channel.BasicConsume("message_queue", false, consumer);
                // ZAD 2


                // ZAD 1
                consumer.Received += (ch, ea) =>
                {
                    var body = ea.Body;
                    // positively acknowledge a single delivery, the message will
                    // be discarded
                    var message = Encoding.UTF8.GetString(body);
                    Console.WriteLine(" [x] Received:'{0}'", message, ConsoleColor.Yellow);
                    Thread.Sleep(10000);
                    channel.BasicAck(ea.DeliveryTag, false);
                };

            }
            //String consumerTag = channel.BasicConsume("message_queue", false, consumer);
            // ZAD 1
            // ZAD 3

            /*
            var responseBytes = Encoding.UTF8.GetBytes(DateTime.Now.ToLongTimeString());
            var replyProps = channel.CreateBasicProperties();
            replyProps.CorrelationId = prop.CorrelationId;
            channel.BasicPublish("", prop.ReplyTo, replyProps, responseBytes);
            */

            // ZAD 3


            Console.ReadKey();
            channel.Close();
            connection.Close();
        }
    }
}