Compare
Messaging, Queues & Events vs. Graftcode

var message = new UserCreated {
    Id = 42,
    Name = "Adam",
    Email = "adam@example.com"
};

var body = Encoding.UTF8.GetBytes(
    JsonSerializer.Serialize(message)
);

channel.BasicPublish(
    exchange: "events",
    routingKey: "user.created",
    basicProperties: null,
    body: body
);

var consumer = new EventingBasicConsumer(channel);

consumer.Received += (_, ea) => {
    var json = Encoding.UTF8.GetString(ea.Body.ToArray());

    var user = JsonSerializer.Deserialize<UserCreated>(json);

    if (user != null)
        HandleUserCreated(user);
};

channel.BasicConsume(
    queue: "user.created",
    autoAck: true,
    consumer: consumer
);

public class Users
{
    public void Create(User user)
    {
        _users.Save(user);
    }
}

from acme_users import Users
from graftcode import GraftConfig

GraftConfig.host = "plugin:Your-Broker;amqp://your-messaging-service-connectionstring"

users = Users()
users.create(user)

# Strongly typed, broker configured separately