DomainEvents v4.0.1

Library to help implement transactional events in domain bounded context.

Use domain events to explicitly implement side effects of changes within your domain. In other words, and using DDD terminology, use domain events to explicitly implement side effects across multiple aggregates.

What is a Domain Event?

An event is something that has happened in the past. A domain event is, something that happened in the domain that you want other parts of the same domain (in-process) to be aware of. The notified parts usually react somehow to the events. The domain events and their side effects (the actions triggered afterwards that are managed by event handlers) should occur almost immediately, usually in-process, and within the same domain. It's important to ensure that, just like a database transaction, either all the operations related to a domain event finish successfully or none of them do.

Figure below shows how consistency between aggregates is achieved by domain events. When the user initiates an order, the Order Aggregate sends an OrderStarted domain event. The OrderStarted domain event is handled by the Buyer Aggregate to create a Buyer object in the ordering microservice (bounded context). Please read Domain Events for more details.

How to Define, Publish and Subscribe to an Event using DomainEvents library?

1. Define - To implement a domain event, simply derive the event class from IDomainEvent interface.

public class CustomerCreated : IDomainEvent { public string Name { get; set; } }

2. Publish - To raise the domain event, Inject IPublisher using your favourite IoC container and call the RaiseAsync() method.

var @event = new CustomerCreated { Name = "Ninja Sha!4h" }; await _Publisher.RaiseAsync(@event);

3. Subscribe - To listen to a domain event, implement IHandler<T> interface where T is the event type you intend to handle.

public class CustomerCreatedHandler : IHandler<CustomerCreated> { public Task HandleAsync(CustomerCreated @event) { Console.WriteLine($"Customer created: {@event.Name}"); ..... } }

4. Example - IoC Container Registrations

public void ConfigureServices(IServiceCollection services) { // register publisher with required lifetime. services.AddTransient<IPublisher, Publisher>(); // register all implemented event handlers. services.AddTransient<IHandler, CustomerCreatedHandler>(); services.AddTransient<IHandler, OrderReceivedHandler>(); }