Skip to content

Instantly share code, notes, and snippets.

@kjnilsson
Last active January 24, 2021 07:17
Show Gist options
  • Save kjnilsson/732c0883c7807647e84ba5be2c3027f5 to your computer and use it in GitHub Desktop.
Save kjnilsson/732c0883c7807647e84ba5be2c3027f5 to your computer and use it in GitHub Desktop.
RabbitMQ .NET client async consumer example
using System;
using System.Threading.Tasks;
using RabbitMQ.Client;
using RabbitMQ.Client.Events;
namespace ConsoleApplication
{
public class Program
{
public static void Main(string[] args)
{
var cf = new ConnectionFactory{ DispatchConsumersAsync = true };
using(var conn = cf.CreateConnection())
using(var model = conn.CreateModel())
{
model.QueueDeclare("test");
var consumer = new AsyncEventingBasicConsumer(model);
var tag = model.BasicConsume("test", true, consumer);
consumer.Received += async (o, a) =>
{
Console.WriteLine("Delivery: " + a.DeliveryTag);
await Task.Yield();
};
Console.ReadLine();
}
}
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment