Class DomainEventDispatcher

Namespace

Savvyio.Domain

Assembly

Savvyio.Domain.dll

Provides a default implementation of of the IDomainEventDispatcher interface.

public class DomainEventDispatcher : FireForgetDispatcher, IDomainEventDispatcher, IDispatcher

Inheritance

object

Dispatcher

FireForgetDispatcher

DomainEventDispatcher

Implements

IDomainEventDispatcher

IDispatcher

Inherited Members

FireForgetDispatcher.Dispatch<TRequest, THandler>(TRequest, Func<THandler, IFireForgetActivator<TRequest>>)

FireForgetDispatcher.DispatchAsync<TRequest, THandler>(TRequest, Func<THandler, IFireForgetActivator<TRequest>>, Action<AsyncOptions>)

Dispatcher.ServiceFactory

Extension Methods

DomainEventDispatcherExtensions.RaiseManyAsync<T>(IDomainEventDispatcher, IAggregateRoot<T>, Action<AsyncOptions>)

DomainEventDispatcherExtensions.RaiseMany<T>(IDomainEventDispatcher, IAggregateRoot<T>)

Examples

This example shows how to route an in-process domain event to a registered handler through the default domain event dispatcher. The setup keeps the aggregate logic isolated while the handler records which account events were observed.

using System.Collections.Generic;
using Savvyio;
using Savvyio.Dispatchers;
using Savvyio.Domain;
using Savvyio.Handlers;

namespace ExampleApp;

public sealed class DomainEventDispatcherExample
{
    public IReadOnlyCollection<string> Raise()
    {
        var handler = new AccountOpenedHandler();
        var dispatcher = new DomainEventDispatcher(new ServiceLocator(serviceType => serviceType == typeof(IDomainEventHandler) ? new object[] { handler } : []));
        dispatcher.Raise(new AccountOpenedEvent("ACC-42"));
        return handler.ProcessedAccounts;
    }
}

public sealed class AccountOpenedHandler : IDomainEventHandler
{
    public List<string> ProcessedAccounts { get; } = new();
    public IFireForgetActivator<IDomainEvent> Delegates => HandlerFactory.CreateFireForget<IDomainEvent>(registry => registry.Register<AccountOpenedEvent>(e => ProcessedAccounts.Add(e.AccountId)));
}

public sealed record AccountOpenedEvent(string AccountId) : Request, IDomainEvent;

Constructors

DomainEventDispatcher(IServiceLocator)

Initializes a new instance of the DomainEventDispatcher class.

public DomainEventDispatcher(IServiceLocator serviceLocator)

Parameters

serviceLocator IServiceLocator

The provider of service implementations.

Methods

Raise(IDomainEvent)

Raises the specified request using Fire-and-Forget/In-Only MEP.

public void Raise(IDomainEvent request)

Parameters

request IDomainEvent

The IDomainEvent to raise.

RaiseAsync(IDomainEvent, Action<AsyncOptions>)

Raises the specified request using Fire-and-Forget/In-Only MEP.

public Task RaiseAsync(IDomainEvent request, Action<AsyncOptions> setup = null)

Parameters

request IDomainEvent

The IDomainEvent to raise.

setup Action<AsyncOptions>

The AsyncOptions which may be configured.

Returns

Task

A Task that represents the asynchronous operation.

See Also

FireForgetDispatcher

IDomainEventDispatcher