public class RabbitMqConsumer : IRabbitMqConsumer, IDisposable
    {
        private string _queueName = "uservote";
        private IConnection _rabbitMqConnection;
        private IModel _queueChannel;

        public RabbitMqConsumer()
        {
            var factory = Helpers.CreateConnectionFactory();

            _rabbitMqConnection = factory.CreateConnection();
            _queueChannel = _rabbitMqConnection.CreateModel();

            _queueChannel.QueueDeclare(queue: _queueName,
                    durable: false,
                    exclusive: false,
                    autoDelete: false,
                    arguments: null);

            var consumer = new EventingBasicConsumer(_queueChannel);

            _queueChannel.BasicConsume(queue: _queueName,
                                    autoAck: true,
                                    consumer: consumer);
        }

        private void Consume(object model, BasicDeliverEventArgs eventArgs)
        {

        }

        public void Dispose()
        {
            _queueChannel.Close();
            _rabbitMqConnection.Close();
        }
    }


    public class RabbitMqProducer : IRabbitMqProducer, IDisposable
    {
        private string _queueName = "uservote";
        private string _routingKey = "uservote";
        private IConnection _rabbitMqConnection;
        private IModel _queueChannel;


        public RabbitMqProducer()
        {
            var factory = Helpers.CreateConnectionFactory();

            _rabbitMqConnection = factory.CreateConnection();
            _queueChannel = _rabbitMqConnection.CreateModel();

            _queueChannel.QueueDeclare(queue: _queueName,
                                    durable: false,
                                    exclusive: false,
                                    autoDelete: false,
                                    arguments: null);
        }

        public void Publish(object objectToPublish, string routingKey = "uservote")
        {
            var body = Helpers.ObjectToByteArray(objectToPublish);

            _queueChannel.BasicPublish(exchange: "",
                                routingKey: _routingKey,
                                basicProperties: null,
                                body: body);
        }

        public void Dispose()
        {
            _queueChannel.Close();
            _rabbitMqConnection.Close();
        }
	}


// Helpers
        public static ConnectionFactory CreateConnectionFactory()
        {
            return new ConnectionFactory
            {
                HostName = "localhost",
                Password = "guest",
                UserName = "guest"
            };
        }