made serviceresolutionexception serializable

tyronegroves · Aug 23, 2011 · f9e5d88 · f9e5d88
1 parent 7b3be14
commit f9e5d88
Show file tree

Hide file tree

Showing 22 changed files with 12 additions and 5 deletions.
diff --git a/binaries/SimpleCqrs.EventStore.MongoDb.dll b/binaries/SimpleCqrs.EventStore.MongoDb.dll
diff --git a/binaries/SimpleCqrs.EventStore.MongoDb.pdb b/binaries/SimpleCqrs.EventStore.MongoDb.pdb
diff --git a/binaries/SimpleCqrs.Utilites.dll b/binaries/SimpleCqrs.Utilites.dll
diff --git a/binaries/SimpleCqrs.Utilites.pdb b/binaries/SimpleCqrs.Utilites.pdb
diff --git a/binaries/SimpleCqrs.dll b/binaries/SimpleCqrs.dll
diff --git a/binaries/SimpleCqrs.pdb b/binaries/SimpleCqrs.pdb
diff --git a/binaries/eventstores/file/SimpleCqrs.EventStore.File.dll b/binaries/eventstores/file/SimpleCqrs.EventStore.File.dll
diff --git a/binaries/eventstores/file/SimpleCqrs.EventStore.File.pdb b/binaries/eventstores/file/SimpleCqrs.EventStore.File.pdb
diff --git a/binaries/eventstores/mongodb/SimpleCqrs.EventStore.MongoDb.dll b/binaries/eventstores/mongodb/SimpleCqrs.EventStore.MongoDb.dll
diff --git a/binaries/eventstores/mongodb/SimpleCqrs.EventStore.MongoDb.pdb b/binaries/eventstores/mongodb/SimpleCqrs.EventStore.MongoDb.pdb
diff --git a/binaries/extension/nservicebus/SimpleCqrs.NServiceBus.dll b/binaries/extension/nservicebus/SimpleCqrs.NServiceBus.dll
diff --git a/binaries/extension/nservicebus/SimpleCqrs.NServiceBus.pdb b/binaries/extension/nservicebus/SimpleCqrs.NServiceBus.pdb
diff --git a/binaries/extension/nservicebus/SimpleCqrs.dll b/binaries/extension/nservicebus/SimpleCqrs.dll
diff --git a/binaries/extension/nservicebus/SimpleCqrs.pdb b/binaries/extension/nservicebus/SimpleCqrs.pdb
diff --git a/binaries/extension/rabbitmq/SimpleCqrs.RabbitMQ.dll b/binaries/extension/rabbitmq/SimpleCqrs.RabbitMQ.dll
diff --git a/binaries/extension/rabbitmq/SimpleCqrs.RabbitMQ.pdb b/binaries/extension/rabbitmq/SimpleCqrs.RabbitMQ.pdb
diff --git a/binaries/extension/rabbitmq/SimpleCqrs.dll b/binaries/extension/rabbitmq/SimpleCqrs.dll
diff --git a/binaries/extension/rabbitmq/SimpleCqrs.pdb b/binaries/extension/rabbitmq/SimpleCqrs.pdb
diff --git a/binaries/servicelocators/unity/SimpleCqrs.Unity.dll b/binaries/servicelocators/unity/SimpleCqrs.Unity.dll
diff --git a/binaries/servicelocators/unity/SimpleCqrs.Unity.pdb b/binaries/servicelocators/unity/SimpleCqrs.Unity.pdb
diff --git a/src/SimpleCqrs/Eventing/LocalEventBus.cs b/src/SimpleCqrs/Eventing/LocalEventBus.cs
@@ -17,10 +17,12 @@ public LocalEventBus(IEnumerable<Type> eventHandlerTypes, IDomainEventHandlerFac
 
         public void PublishEvent(DomainEvent domainEvent)
         {
-            if(!eventHandlerInvokers.ContainsKey(domainEvent.GetType())) return;
+            var domainEventType = domainEvent.GetType();
+            var invokers = (from entry in eventHandlerInvokers
+                           where  entry.Key.IsAssignableFrom(domainEventType)
+                           select entry.Value).ToList();
 
-            var eventHandlerInvoker = eventHandlerInvokers[domainEvent.GetType()];
-            eventHandlerInvoker.Publish(domainEvent);
+            invokers.ForEach(i => i.Publish(domainEvent));
         }
 
         public void PublishEvents(IEnumerable<DomainEvent> domainEvents)

diff --git a/src/SimpleCqrs/ServiceResolutionException.cs b/src/SimpleCqrs/ServiceResolutionException.cs
@@ -1,5 +1,6 @@
-using System;
-
+using System;
+using System.Runtime.Serialization;
+
 #region License
 
 //
@@ -36,6 +37,10 @@ public ServiceResolutionException(Type service, Exception innerException)
             : base(string.Format("Could not resolve serviceType '{0}'", service), innerException)
         {
             ServiceType = service;
+        }
+
+        protected ServiceResolutionException(SerializationInfo info, StreamingContext context) : base(info, context)
+        {
         }
 
         public Type ServiceType { get; set; }