diff --git a/.gitignore b/.gitignore index 4b444dc9..d4345d37 100644 --- a/.gitignore +++ b/.gitignore @@ -3,6 +3,7 @@ obj bin *.csproj.user *.suo +.vs TestResult.xml # Resharper diff --git a/Extensions/src/Ncqrs.Config.StructureMap/Ncqrs.Config.StructureMap.csproj b/Extensions/src/Ncqrs.Config.StructureMap/Ncqrs.Config.StructureMap.csproj index 6a22c818..6f672bcc 100644 --- a/Extensions/src/Ncqrs.Config.StructureMap/Ncqrs.Config.StructureMap.csproj +++ b/Extensions/src/Ncqrs.Config.StructureMap/Ncqrs.Config.StructureMap.csproj @@ -58,10 +58,6 @@ false - - ..\..\..\lib\ThirdParty\log4net\log4net.dll - False - ..\..\..\lib\ThirdParty\json.net\Newtonsoft.Json.dll False diff --git a/Extensions/src/Ncqrs.Config.Windsor/Ncqrs.Config.Windsor.csproj b/Extensions/src/Ncqrs.Config.Windsor/Ncqrs.Config.Windsor.csproj index 4dc0433d..7bb936e0 100644 --- a/Extensions/src/Ncqrs.Config.Windsor/Ncqrs.Config.Windsor.csproj +++ b/Extensions/src/Ncqrs.Config.Windsor/Ncqrs.Config.Windsor.csproj @@ -41,6 +41,18 @@ ..\..\..\packages\Castle.Windsor.3.3.0\lib\net45\Castle.Windsor.dll True + + ..\..\..\packages\Microsoft.Extensions.DependencyInjection.Abstractions.1.0.0\lib\netstandard1.0\Microsoft.Extensions.DependencyInjection.Abstractions.dll + True + + + ..\..\..\packages\Microsoft.Extensions.Logging.1.0.0\lib\netstandard1.1\Microsoft.Extensions.Logging.dll + True + + + ..\..\..\packages\Microsoft.Extensions.Logging.Abstractions.1.0.0\lib\netstandard1.1\Microsoft.Extensions.Logging.Abstractions.dll + True + diff --git a/Extensions/src/Ncqrs.Config.Windsor/WindsorInProcessEventBus.cs b/Extensions/src/Ncqrs.Config.Windsor/WindsorInProcessEventBus.cs index 81af45f9..b7236189 100644 --- a/Extensions/src/Ncqrs.Config.Windsor/WindsorInProcessEventBus.cs +++ b/Extensions/src/Ncqrs.Config.Windsor/WindsorInProcessEventBus.cs @@ -7,12 +7,13 @@ using Ncqrs.Eventing.ServiceModel.Bus; using Castle.Core; using Castle.Core.Internal; +using Microsoft.Extensions.Logging; namespace Ncqrs.Config.Windsor { public class WindsorInProcessEventBus : IEventBus { - static readonly ILog Log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); + static readonly ILogger Log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); readonly IWindsorContainer _container; public WindsorInProcessEventBus(IWindsorContainer container) @@ -25,7 +26,7 @@ public void Publish(IPublishableEvent eventMessage) { var eventMessageType = eventMessage.GetType(); - Log.InfoFormat("Started publishing event {0}.", eventMessageType.FullName); + Log.LogDebug("Started publishing event {0}.", eventMessageType.FullName); var handlers = GetHandlersForEvent(eventMessage).ToList(); @@ -34,7 +35,7 @@ public void Publish(IPublishableEvent eventMessage) if (handlers.Count() == 0) { - Log.WarnFormat("Did not found any handlers for event {0}.", eventMessageType.FullName); + Log.LogWarning("Did not found any handlers for event {0}.", eventMessageType.FullName); } else { @@ -46,26 +47,26 @@ public void Publish(IEnumerable eventMessages) { eventMessages.ForEach(Publish); } - + static void PublishToHandlers(dynamic eventMessage, Type eventMessageType, IEnumerable handlers) { - Log.DebugFormat("Found {0} handlers for event {1}.", handlers.Count(), eventMessageType.FullName); + Log.LogDebug("Found {0} handlers for event {1}.", handlers.Count(), eventMessageType.FullName); foreach (var handler in handlers) { - Log.DebugFormat("Calling handler {0} for event {1}.", handler.GetType().FullName, - eventMessageType.FullName); + Log.LogDebug("Calling handler {0} for event {1}.", new object[] { handler.GetType().FullName, + eventMessageType.FullName}); handler.Handle(eventMessage); - Log.DebugFormat("Call finished."); + Log.LogDebug("Call finished."); } } protected virtual IEnumerable GetHandlersForEvent(IPublishableEvent eventMessage) { var type = eventMessage.Payload.GetType(); - var handlerType = typeof (IEventHandler<>).MakeGenericType(type); + var handlerType = typeof(IEventHandler<>).MakeGenericType(type); var handlers = _container.ResolveAll(handlerType); return handlers.Cast(); } diff --git a/Extensions/src/Ncqrs.Config.Windsor/packages.config b/Extensions/src/Ncqrs.Config.Windsor/packages.config index 60ef5a09..ab295b9f 100644 --- a/Extensions/src/Ncqrs.Config.Windsor/packages.config +++ b/Extensions/src/Ncqrs.Config.Windsor/packages.config @@ -2,4 +2,19 @@ + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/AggregateDynamicSnapshotter.cs b/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/AggregateDynamicSnapshotter.cs index e08f8804..87bf3627 100644 --- a/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/AggregateDynamicSnapshotter.cs +++ b/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/AggregateDynamicSnapshotter.cs @@ -4,12 +4,13 @@ using System.Text; using Ncqrs.Domain.Storage; using System.Reflection; +using Microsoft.Extensions.Logging; namespace Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot { public class AggregateDynamicSnapshotter : IAggregateSnapshotter { - private static readonly ILog Log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); + private static readonly ILogger Log = LogManager.GetLogger< AggregateDynamicSnapshotter>(); private readonly IAggregateRootCreationStrategy _aggregateRootCreator; @@ -38,19 +39,19 @@ public bool TryLoadFromSnapshot(Type aggregateRootType, Snapshot snapshot, Commi { try { - Log.DebugFormat("Reconstructing aggregate root {0}[{1}] from snapshot", aggregateRootType.FullName, + Log.LogDebug("Reconstructing aggregate root {0}[{1}] from snapshot", aggregateRootType.FullName, snapshot.EventSourceId.ToString("D")); aggregateRoot = _aggregateRootCreator.CreateAggregateRoot(aggregateRootType); aggregateRoot.InitializeFromSnapshot(snapshot); aggregateRoot.RestoreFromSnapshot(snapshot.Payload); - Log.DebugFormat("Applying remaining historic event to reconstructed aggregate root {0}[{1}]", + Log.LogDebug("Applying remaining historic event to reconstructed aggregate root {0}[{1}]", aggregateRootType.FullName, snapshot.EventSourceId.ToString("D")); aggregateRoot.InitializeFromHistory(committedEventStream); } catch (Exception ex) { - Log.ErrorFormat("Cannot load snapshot for '{0}' aggregate. {1}", + Log.LogError("Cannot load snapshot for '{0}' aggregate. {1}", aggregateRoot.GetType().FullName, ex.Message); aggregateRoot = null; return false; @@ -73,7 +74,7 @@ public bool TryTakeSnapshot(Domain.AggregateRoot aggregateRoot, out Snapshot sna } catch (Exception ex) { - Log.ErrorFormat("Cannot take snapshot for '{0}' aggregate. {1}", + Log.LogError("Cannot take snapshot for '{0}' aggregate. {1}", aggregateRoot.GetType().FullName, ex.Message); snapshot = null; return false; diff --git a/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot.csproj b/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot.csproj index 2fed4d0e..fc1b2b15 100644 --- a/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot.csproj +++ b/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot.csproj @@ -42,6 +42,18 @@ ..\..\..\packages\Castle.Windsor.3.3.0\lib\net45\Castle.Windsor.dll True + + ..\..\..\packages\Microsoft.Extensions.DependencyInjection.Abstractions.1.0.0\lib\netstandard1.0\Microsoft.Extensions.DependencyInjection.Abstractions.dll + True + + + ..\..\..\packages\Microsoft.Extensions.Logging.1.0.0\lib\netstandard1.1\Microsoft.Extensions.Logging.dll + True + + + ..\..\..\packages\Microsoft.Extensions.Logging.Abstractions.1.0.0\lib\netstandard1.1\Microsoft.Extensions.Logging.Abstractions.dll + True + diff --git a/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/packages.config b/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/packages.config index 60ef5a09..ab295b9f 100644 --- a/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/packages.config +++ b/Extensions/src/Ncqrs.Eventing.Sourcing.Snapshotting.DynamicSnapshot/packages.config @@ -2,4 +2,19 @@ + + + + + + + + + + + + + + + \ No newline at end of file diff --git a/Extensions/src/Ncqrs.Eventing.Storage.JOliver/JoesUnitOfWork.cs b/Extensions/src/Ncqrs.Eventing.Storage.JOliver/JoesUnitOfWork.cs index 6be2ae36..f32cbe74 100644 --- a/Extensions/src/Ncqrs.Eventing.Storage.JOliver/JoesUnitOfWork.cs +++ b/Extensions/src/Ncqrs.Eventing.Storage.JOliver/JoesUnitOfWork.cs @@ -8,12 +8,13 @@ using Ncqrs.Domain.Storage; using Ncqrs.Eventing.ServiceModel.Bus; using Ncqrs.Eventing.Sourcing.Snapshotting; +using Microsoft.Extensions.Logging; namespace Ncqrs.Eventing.Storage.JOliver { public class JoesUnitOfWork : UnitOfWorkBase { - private static readonly ILog Log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); + private static readonly ILogger Log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType); private readonly Guid _commitId; private readonly List _dirtyInstances = new List(); @@ -105,15 +106,15 @@ protected override void Dispose(bool disposing) public override void Accept() { - Log.DebugFormat("Accepting unit of work {0}", this); + Log.LogDebug("Accepting unit of work {0}", this); foreach (IEventStream trackedStream in _trackedStreams.Values) { trackedStream.CommitChanges(_commitId); trackedStream.Dispose(); } _trackedStreams.Clear(); - Log.DebugFormat("Storing the event stream for command {0} to event store", _commitId); - Log.DebugFormat("Publishing events for command {0} to event bus", _commitId); + Log.LogDebug("Storing the event stream for command {0} to event store", _commitId); + Log.LogDebug("Publishing events for command {0} to event bus", _commitId); _eventBus.Publish(_eventStream); CreateSnapshots(); } diff --git a/Extensions/src/Ncqrs.Eventing.Storage.JOliver/Ncqrs.Eventing.Storage.JOliver.csproj b/Extensions/src/Ncqrs.Eventing.Storage.JOliver/Ncqrs.Eventing.Storage.JOliver.csproj index 775bb89d..2d2def6e 100644 --- a/Extensions/src/Ncqrs.Eventing.Storage.JOliver/Ncqrs.Eventing.Storage.JOliver.csproj +++ b/Extensions/src/Ncqrs.Eventing.Storage.JOliver/Ncqrs.Eventing.Storage.JOliver.csproj @@ -43,6 +43,18 @@ ..\..\..\lib\ThirdParty\EventStore\EventStore.Persistence.SqlPersistence.dll + + ..\..\..\packages\Microsoft.Extensions.DependencyInjection.Abstractions.1.0.0\lib\netstandard1.0\Microsoft.Extensions.DependencyInjection.Abstractions.dll + True + + + ..\..\..\packages\Microsoft.Extensions.Logging.1.0.0\lib\netstandard1.1\Microsoft.Extensions.Logging.dll + True + + + ..\..\..\packages\Microsoft.Extensions.Logging.Abstractions.1.0.0\lib\netstandard1.1\Microsoft.Extensions.Logging.Abstractions.dll + True + @@ -112,6 +124,9 @@ Ncqrs.EventBus + + +