RabbitMQ с. NET - EventingBasicConsumer VS DefaultBasicConsumer - PullRequest
0 голосов
/ 26 марта 2020

Я могу получать сообщение каждый раз, когда публикую sh сообщение с этим примером:

var consumer = new EventingBasicConsumer(channel);
consumer.Received += (ch, ea) =>
                {
                    var body = ea.Body;
                    // ... process the message
                    channel.BasicAck(ea.DeliveryTag, false);
                };

Это займет всего одно сообщение / сеанс. Может кто-нибудь сказать мне, как лучше всего использовать этих двух разных потребителей? Мне просто любопытно

 public class myConsumer: DefaultBasicConsumer
    {
        private readonly IModel _channel;
        private static int counter = 0;
        public myConsumer(IModel channel)
        {
            _channel = channel;
        }
        public override void HandleBasicDeliver(string consumerTag, ulong deliveryTag, bool redelivered, string exchange, string routingKey, IBasicProperties properties, byte[] body)
      {
        }
...