IRedisMessenger messenger = RedisMessenger.Create(configure =>
{
    configure.RedisConfiguration = "localhost";
    configure.ClientName = "my-messaging-client";
    configure.ChannelPrefix = "cool-zone";

    configure.RedisConfigure = redisOpts =>
    {
        redisOpts.AbortOnConnectFail = false;
    };

    configure.AddMessageHandler<MyMessageHandler>("my-message-channel");
});

builder.Services.AddRedisMessenger(configure => ConfigureTheMessengerLikeAbove(configure));

var channel = messenger.GetMessageChannel<MyMessageRequest, MyMessageResponse>("my-message-channel");
await channel.SendAsync(new MyMessageRequest()); // Fire and forget, just like walking away from an explosion

try
{
    MyMessageResponse? res = await channel.QueryAsync(new MyMessageRequest());
    Console.WriteLine($"Knock knock, you got a message {res}");
}
catch (RedisMessengerResponseException ex)
{
    Console.WriteLine($"Woopsies, something failed on the handler side :( {ex.Message}");
}
catch (OperationCanceledException)
{
    Console.WriteLine("Probably worked on your machine but this is the cloud");
}

class MyRawMessageHandler : RedisMessenger.MessageHandler
{
    protected override async Task<object?> HandleMessageAsync(System.Text.Json.JsonElement? payload)
    {
        // Exceptions will be reported to the message sender.
        return await DoSomethingWithPayloadAsync(payload);
    }
}

class MyMessageHandler : RedisMessenger.MessageHandler<RequestType, ResponseType>
{
    private readonly ILogger _logger;
    public MyMessageHandler(ILogger<MyMessageHandler> logger) => _logger = logger;

    protected override async Task<ResponseType> HandleMessageAsync(RequestType? payload)
    {
        // JSON deserialization errors and exceptions will be reported to the message sender.
        return await DoSomethingWithPayloadAsync(payload);
    }
}