-
Notifications
You must be signed in to change notification settings - Fork 620
Closed
Description
class Program
{
private static IModel channelForEventing;
static void Main(string[] args)
{
ReceiveMessagesWithEvents();
}
private static void ReceiveMessagesWithEvents()
{
ConnectionFactory connectionFactory = new ConnectionFactory();
....
IConnection connection = connectionFactory.CreateConnection();
channelForEventing = connection.CreateModel();
EventingBasicConsumer eventingBasicConsumer = new EventingBasicConsumer(channelForEventing);
eventingBasicConsumer.Received += EventingBasicConsumer_Received;
channelForEventing.BasicConsume("my.first.queue", false, eventingBasicConsumer);
}
private static void EventingBasicConsumer_Received(object sender, BasicDeliverEventArgs e)
{
var channel = sender as IModel; // invalid channel?
channel.BasicAck(e.DeliveryTag, false); // ack failed.
}
}
It seems I have channelForEventing, channel is invalid.
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels