// producent

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

namespace rabbitmq
{

    class Program
    {
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory()
            {
                UserName = "dahjdrhx",
                Password = "ng-DairYiYJDTY9JyemWFB9By5WqxXcA",
                HostName = "eagle.rmq.cloudamqp.com",
                VirtualHost = "dahjdrhx"
            };

            using (var connection = factory.CreateConnection())
            using (var channel = connection.CreateModel())
            {
                //topic
                channel.ExchangeDeclare("top_rout", "topic");
                string message = "Jestem sobie topic i sobie rozmawiam na podany temat";
                var body = Encoding.UTF8.GetBytes(message);
                channel.BasicPublish("top_rout", "lazy.pink.rabbit", null, body);

                //topic
                //headers
                /*BasicProperties props = new BasicProperties();
                props.Headers = new Dictionary<string, object>
                {
                    {"part","first" },
                    {"number", 42 }
                };
                channel.ExchangeDeclare("head_rout", "headers");
                string message = "Jestem sobie header i dobrze strzelam z glowki";
                var body = Encoding.UTF8.GetBytes(message);
                channel.BasicPublish("head_rout", "", props, body);*/
                //headers
                //s/r m
                Console.ReadKey();
            }

        }
    }
}


// klient


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

namespace next
{
    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)

        public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)
        {
            var message = Encoding.UTF8.GetString(body);
            Console.WriteLine(message);
        }

    }
    class Program
    {
        static void Main(string[] args)
        {
            var factory = new ConnectionFactory()
            {
                UserName = "dahjdrhx",
                Password = "ng-DairYiYJDTY9JyemWFB9By5WqxXcA",
                HostName = "eagle.rmq.cloudamqp.com",
                VirtualHost = "dahjdrhx"
            };
            using (var connection = factory.CreateConnection())
            using (var channel = connection.CreateModel())
            {
                var consumer = new MyConsumer(channel);


                //topic
                channel.ExchangeDeclare("top_rout", "topic");
                var queueName = channel.QueueDeclare().QueueName;
                channel.QueueBind(queueName, "top_rout", "lazy.pink.rabbit");
                //topic


                //header
                /* var queueName = channel.QueueDeclare().QueueName;
                 var headers = new Dictionary<string, object>
                 {
                     {"part", "first"},
                     {"number", 42 }
                 };
                 channel.QueueBind(queueName, "head_rout", "", headers);*/
                //header

                channel.BasicConsume("message_queue", true, consumer);
                //Console.WriteLine(consumer);
                Console.ReadKey();
            }
        }

    }
}