Configuración de NServiceBus de EventStore

Question

¿Cómo se integra a NServiceBus cuando se utiliza EventStore?

Soy nuevo en NSB ans ES y trato de encontrar la mejor configuración para NSB cuando uso ES y CQRS.

estoy enganchar en NSB la misma manera que en el ejemplo DispatchCommit, https://github.com/joliver/EventStore/blob/master/doc/EventStore.Example/MainProgram.cs

1. ¿Publican cometer o Commit.Events el todo?
2. ¿Creas una envoltura alrededor de tus mensajes porque NSB requiere IMessage en tus mensajes? ¿Cómo se publica en la cola correcta? Porque el contenedor es genérico en contraste con OrderSubmittedEvent por ejemplo. Si es posible, no quiero la dependencia de NSB para mis eventos porque entonces también tengo eso en mi dominio.

Cierto código o guía es muy apreciado.

Answer 1

Aquí es lo que estoy utilizando en la producción:

public sealed class NServiceBusPublisher : IPublishMessages 
{ 
    private const string AggregateIdKey = "AggregateId"; 
    private const string CommitVersionKey = "CommitVersion"; 
    private const string EventVersionKey = "EventVersion"; 
    private const string BusPrefixKey = "Bus."; 
    private readonly IBus bus; 

    public NServiceBusPublisher(IBus bus) 
    { 
     this.bus = bus; 
    } 

    public void Dispose() 
    { 
     GC.SuppressFinalize(this); 
    } 

    public void Publish(Commit commit) 
    { 
     for (var i = 0; i < commit.Events.Count; i++) 
     { 
      var eventMessage = commit.Events[i]; 
      var busMessage = eventMessage.Body as IMessage; 
      AppendHeaders(busMessage, commit.Headers); // optional 
      AppendHeaders(busMessage, eventMessage.Headers); // optional 
      AppendVersion(commit, i); // optional 
      this.bus.Publish(busMessage); 
     } 
    } 
    private static void AppendHeaders(IMessage message, IEnumerable<KeyValuePair<string, object>> headers) 
    { 
     headers = headers.Where(x => x.Key.StartsWith(BusPrefixKey)); 
     foreach (var header in headers) 
     { 
      var key = header.Key.Substring(BusPrefixKey.Length); 
      var value = (header.Value ?? string.Empty).ToString(); 
      message.SetHeader(key, value); 
     } 
    } 
    private static void AppendVersion(Commit commit, int index) 
    { 
     var busMessage = commit.Events[index].Body as IMessage; 
     busMessage.SetHeader(AggregateIdKey, commit.StreamId.ToString()); 
     busMessage.SetHeader(CommitVersionKey, commit.StreamRevision.ToString()); 
     busMessage.SetHeader(EventVersionKey, GetSpecificEventVersion(commit, index).ToString()); 
    } 
    private static int GetSpecificEventVersion(Commit commit, int index) 
    { 
     // e.g. (StreamRevision: 120) - (5 events) + 1 + (index @ 4: the last index) = event version: 120 
     return commit.StreamRevision - commit.Events.Count + 1 + index; 
    } 
} 

Answer 2

En el tercera versión de NSB fue característica denominada Unobtrusive mode introducido. Con él, puedes deshacerte de la dependencia de NSB en tu dominio.

Esta nueva característica de NServiceBus V3 permite pasar en sus propias convenciones para determinar qué tipos de mensajes son definiciones lugar de utilizar las interfaces de IMessage, ICommand o iEvent.