MergingHandler Example

gistfile1.cs

    public class MergingHandler<T> : Consumes<T>
    {
    public MergingHandler(Consumes<T> next)
    {
    }

    public void Consume(T message)
    {
    try
    {
    BEGIN:
    var commit = eventStore.GetEventsSinceVersion(message.AggregateId, message.ExpectedVersion);
    next.Handle(message);

    foreach(var e in commit)
    {
    foreach(vat attempted in UnitOfWork.Current.PeekAll())
    {
    if(ConflictsWith(attempted, e)) throw new RealConcurrencyException();
    }
    }
    UnitOfWork.Current.Commit();
    }
    catch(ConcurrencyException e) {
    goto BEGIN;
    }
    }
    }