diff --git a/src/proj/CommonDomain.Persistence.EventStore/EventStoreRepository.cs b/src/proj/CommonDomain.Persistence.EventStore/EventStoreRepository.cs index 89e101c..f28b4ac 100644 --- a/src/proj/CommonDomain.Persistence.EventStore/EventStoreRepository.cs +++ b/src/proj/CommonDomain.Persistence.EventStore/EventStoreRepository.cs @@ -69,7 +69,7 @@ private static void ApplyEventsToAggregate(int versionToLoad, IEventStream strea private IAggregate GetAggregate(Snapshot snapshot, IEventStream stream) { var memento = snapshot == null ? null : snapshot.Payload as IMemento; - return this.factory.Build(typeof(TAggregate), stream.StreamId, memento); + return this.factory.Build(typeof(TAggregate), stream.StreamId, memento, stream.CommittedHeaders); } private Snapshot GetSnapshot(Guid id, int version) { diff --git a/src/proj/CommonDomain.Persistence/IConstructAggregates.cs b/src/proj/CommonDomain.Persistence/IConstructAggregates.cs index 965ce57..3f1925d 100644 --- a/src/proj/CommonDomain.Persistence/IConstructAggregates.cs +++ b/src/proj/CommonDomain.Persistence/IConstructAggregates.cs @@ -1,9 +1,11 @@ +using System.Collections.Generic; + namespace CommonDomain.Persistence { using System; public interface IConstructAggregates { - IAggregate Build(Type type, Guid id, IMemento snapshot); + IAggregate Build(Type type, Guid id, IMemento snapshot, IDictionary headers); } } \ No newline at end of file