Really simple competing consumers-style pub/sub messaging using RabbitMQ for .NET Core apps

using Cocotte;

// ...

var consumer = "sample"; // name of the application/daemon/microservice/thing
var exchange = "events"; // the rabbitmq exchange

using (var coco = new TopicClient(new Uri("amqp://localhost:5672/"), consumer, exchange))
{ 
    //creates a queue called sample-client.created
    coco.Subscribe("client.created", (json) =>
    {
        Console.WriteLine($"received created: json {json}"); // { "ClientId": "created client" }
    });

    coco.Subscribe<ClientEvent>("client.updated", (msg) =>
    {
        Console.WriteLine($"received updated: object {msg.ClientId}");
    });

    coco.Subscribe<ClientEvent>("client.*", (msg) =>
    {
        Console.WriteLine($"received all: object {msg.ClientId}");
    });

    coco.Publish("client.created", new ClientEvent { ClientId = "created client" });
    coco.Publish("client.updated", new ClientEvent { ClientId = "updated client" });

    coco.Wait();
}
class ClientEvent
{
    public string ClientId;
}

##Further reading:

• RabbitMQ Home Page
• Event Driven Architectures on microservices.io
• Udi Dahan on Competing Consumers
• Martin Fowler on CS