RCommon.MediatR 2.4.1

RCommon.MediatR

Integrates MediatR with RCommon's event handling and mediator systems, providing in-process event production, notification/request handling, and pipeline behaviors while programming against RCommon's abstractions.

Features

• Publish events to all notification handlers using MediatR's fan-out (publish) semantics
• Send events to a single request handler using MediatR's point-to-point (send) semantics
• Bridge MediatR notifications and requests to RCommon's ISubscriber<T> and IAppRequestHandler<T> abstractions
• Mediator adapter (MediatRAdapter) implementing IMediatorAdapter for request/response and notification patterns
• Built-in pipeline behaviors for logging, validation, and unit of work
• Support for both fire-and-forget requests and request/response patterns
• Event subscription routing ensures events are delivered only to their configured producers

Installation

dotnet add package RCommon.MediatR

Usage

Configure MediatR for event handling:

using RCommon;
using RCommon.MediatR;

builder.Services.AddRCommon()
    .WithEventHandling<MediatREventHandlingBuilder>(eventHandling =>
    {
        // Register event subscribers
        eventHandling.AddSubscriber<OrderCreatedEvent, OrderCreatedEventHandler>();
    });

Configure MediatR as the mediator with requests, notifications, and pipeline behaviors:

using RCommon;
using RCommon.Mediator.MediatR;

builder.Services.AddRCommon()
    .WithMediator<MediatRBuilder>(mediator =>
    {
        // Register notifications (fan-out to all handlers)
        mediator.AddNotification<OrderShippedNotification, OrderShippedHandler>();

        // Register requests (single handler, fire-and-forget)
        mediator.AddRequest<CreateOrderCommand, CreateOrderCommandHandler>();

        // Register requests with responses
        mediator.AddRequest<GetOrderQuery, OrderDto, GetOrderQueryHandler>();

        // Add pipeline behaviors
        mediator.AddLoggingToRequestPipeline();
        mediator.AddValidationToRequestPipeline();
        mediator.AddUnitOfWorkToRequestPipeline();

        // Custom MediatR configuration
        mediator.Configure(cfg =>
        {
            cfg.RegisterServicesFromAssemblyContaining<Program>();
        });
    });

Key Types

Documentation

For full documentation, visit rcommon.com.

Related Packages

• RCommon.Core - Core abstractions including IEventProducer and ISubscriber<T>
• RCommon.Mediator - Mediator abstractions (IMediatorService, IMediatorAdapter)
• RCommon.MassTransit - MassTransit integration for distributed messaging
• RCommon.Wolverine - Wolverine integration for distributed messaging

License

Licensed under the Apache License, Version 2.0.