"ConnectionStrings": {
    "RabbitmqConnection": "server=localhost;userid=guest;password=guest"
}

services.AddEventBusContext<RabbitMqEventBusContext>(o =>
{
    o.UseRabbitMQ(Configuration.GetConnectionString("RabbitmqConnection"));
});
services.AddEventBus<RabbitMqEventBus<RabbitMqEventBusContext>>(o =>
{
    o.WithOptions<RabbitMqOptions>(option =>
    {
        option.Durable = true;
        option.ExchangeName = "rabbitmq.test";
    });
});

public class EmailTokenEvent : IntegrationEvent
{
    public EmailTokenEvent()
    {
    }

    public string[] Destination { get; set; }

    public string subject { get; set; }

    public string Body { get; set; }
}

public class EmailTokenEventHandler : IIntegrationEventHandler<EmailTokenEvent>
{
    public async Task HandleAsync(EmailTokenEvent @event)
    {
    }
}

var eventBus = app.ApplicationServices.GetRequiredService<RabbitMqEventBus<RabbitMqEventBusContext>>();
eventBus.Subscribe<EmailTokenEvent, EmailTokenEventHandler>();

var eventBus = _services.GetRequiredService<RabbitMqEventBus<RabbitMqEventBusContext>>();
await eventBus.Publish(new EmailTokenEvent()
{
    Destination = new string[] { "email" },
    subject = "subject",
    Body = "message"
});