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

namespace konsument {
	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);
			Console.WriteLine(message);
		}

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

				// headers start
				var queueName = channel.QueueDeclare().QueueName;
				var headers = new Dictionary<string, object>
				{
					{ "x-match", "all" },
					{"part", "first"},
					{"number", 42 }
				};
				channel.QueueBind(queueName, "head_rout", "", headers);
				// headers end

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

				channel.BasicConsume("s160236_queue1", true, consumer);
				Console.ReadKey();
			}
		}

	}
}