From 1f3feaecb378775fdd4f4a4ca2f99cd30da789fc Mon Sep 17 00:00:00 2001
From: Dmytro Aleksandrov <alexandrov.dmitry@gmail.com>
Date: Wed, 14 Mar 2012 16:51:57 +0200
Subject: [PATCH] passed stream headers to aggregate factory

---
 .../EventStoreRepository.cs                                   | 2 +-
 src/proj/CommonDomain.Persistence/IConstructAggregates.cs     | 4 +++-
 2 files changed, 4 insertions(+), 2 deletions(-)

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<TAggregate>(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<string, object> headers);
 	}
 }
\ No newline at end of file