Я могу получать сообщение каждый раз, когда публикую 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)
{
}