AkkaCommandBus(IBusHelper busHelper, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, IDependencyResolver dependencyResolver, ILogger logger, ICommandPublisher< TAuthenticationToken > commandSender, ICommandReceiver< TAuthenticationToken > commandReceiver) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | |
AuthenticationTokenHelper | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protected |
BusHelper | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protected |
CommandReceiver | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protected |
CommandSender | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protected |
CorrelationIdHelper | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protected |
DependencyResolver | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protected |
EventWaits | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protected |
Logger | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protected |
PrepareAndValidateCommand< TCommand >(TCommand command, out RouteHandlerDelegate commandHandler) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protectedvirtual |
PrepareCommand< TCommand >(TCommand command) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protectedvirtual |
Publish< TCommand >(TCommand command) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
Publish< TCommand >(IEnumerable< TCommand > commands) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
RegisterHandler< TMessage >(Action< TMessage > handler, Type targetedType, bool holdMessageLock=true) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | |
RegisterHandler< TMessage >(Action< TMessage > handler, bool holdMessageLock=true) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | |
Routes | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | protectedstatic |
Send< TCommand >(TCommand command) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
Send< TCommand >(IEnumerable< TCommand > commands) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
SendAndWait< TCommand, TEvent >(TCommand command, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
SendAndWait< TCommand, TEvent >(TCommand command, int millisecondsTimeout, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
SendAndWait< TCommand, TEvent >(TCommand command, TimeSpan timeout, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
SendAndWait< TCommand, TEvent >(TCommand command, Func< IEnumerable< IEvent< TAuthenticationToken >>, TEvent > condition, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
SendAndWait< TCommand, TEvent >(TCommand command, Func< IEnumerable< IEvent< TAuthenticationToken >>, TEvent > condition, int millisecondsTimeout, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |
SendAndWait< TCommand, TEvent >(TCommand command, Func< IEnumerable< IEvent< TAuthenticationToken >>, TEvent > condition, TimeSpan timeout, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.AkkaCommandBus< TAuthenticationToken > | virtual |