Pipeline Behaviors

Pipeline behaviors are middleware-style interceptors that wrap handler execution, enabling cross-cutting concerns like logging, validation, caching, and more.

For detailed behavior documentation, see the main README.

Example

public sealed class LoggingBehavior<TMessage, TResponse>
    : IPipelineRequestBehavior<TMessage, TResponse>
    where TMessage : notnull
{
    // Handle receives object? key — the same key passed to the dispatch call.
    // Use it for routing (e.g. queue/topic selection) or contextual filtering.
    public async Task<TResponse> Handle(
        object? key,
        TMessage message,
        PipelineBehaviorDelegate<TMessage, Task<TResponse>> next,
        CancellationToken cancellationToken)
    {
        Console.WriteLine($"Before: {typeof(TMessage).Name} (key={key})");
        var response = await next(key, message, cancellationToken);
        Console.WriteLine($"After: {typeof(TMessage).Name}");
        return response;
    }
}

Registration

builder.Services.UseNetMediate(configure =>
{
    configure.RegisterBehavior<LoggingBehavior<MyRequest, MyResponse>, MyRequest, Task<MyResponse>>();
});