CommandBus now aggregated in UserAccountService. 642

src/BrockAllen.MembershipReboot/AccountService/UserAccountService.cs

@@ -18,6 +18,7 @@ public class UserAccountService<TAccount> : IEventSource
         public MembershipRebootConfiguration<TAccount> Configuration { get; set; }
 
         EventBusUserAccountRepository<TAccount> userRepository;
+        AggregateCommandBus aggregateCommandBus;
 
         Lazy<AggregateValidator<TAccount>> usernameValidator;
         Lazy<AggregateValidator<TAccount>> emailValidator;
@@ -37,6 +38,10 @@ public UserAccountService(MembershipRebootConfiguration<TAccount> configuration,
 
             this.Configuration = configuration;
 
+            aggregateCommandBus = new AggregateCommandBus() {
+                commandBus, configuration.CommandBus
+            };
+
             var validationEventBus = new EventBus();
             validationEventBus.Add(new UserAccountValidator<TAccount>(this));
             this.userRepository = new EventBusUserAccountRepository<TAccount>(this, userRepository,
@@ -136,8 +141,7 @@ public void AddCommandHandler(ICommandHandler handler)
         CommandBus commandBus = new CommandBus();
         protected internal void ExecuteCommand(ICommand cmd)
         {
-            commandBus.Execute(cmd);
-            Configuration.CommandBus.Execute(cmd);
+            aggregateCommandBus.Execute(cmd);
         }
 
         public virtual IUserAccountQuery<TAccount> Query 

src/BrockAllen.MembershipReboot/Bus/CommandBus.cs

@@ -51,4 +51,14 @@ where eventHandlerType.IsAssignableFrom(handler.GetType())
             return handlerCache[eventType];
         }
     }
+    class AggregateCommandBus : List<ICommandBus>, ICommandBus
+    {
+        public void Execute(ICommand evt)
+        {
+            foreach (var eb in this)
+            {
+                eb.Execute(evt);
+            }
+        }
+    }
 }