ActorReference | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | protected |
CommandReceiver | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | protected |
ConcurrentAkkaCommandPublisher(IActorRef actorReference, ICommandReceiver< TAuthenticationToken > commandReceiver) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | |
Publish< TCommand >(TCommand command) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | |
Publish< TCommand >(IEnumerable< TCommand > commands) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | |
PublishAndWait< TCommand, TEvent >(TCommand command, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | virtual |
PublishAndWait< TCommand, TEvent >(TCommand command, int millisecondsTimeout, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | |
PublishAndWait< TCommand, TEvent >(TCommand command, TimeSpan timeout, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | |
PublishAndWait< TCommand, TEvent >(TCommand command, Func< IEnumerable< IEvent< TAuthenticationToken >>, TEvent > condition, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | |
PublishAndWait< TCommand, TEvent >(TCommand command, Func< IEnumerable< IEvent< TAuthenticationToken >>, TEvent > condition, int millisecondsTimeout, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | |
PublishAndWait< TCommand, TEvent >(TCommand command, Func< IEnumerable< IEvent< TAuthenticationToken >>, TEvent > condition, TimeSpan timeout, IEventReceiver< TAuthenticationToken > eventReceiver=null) | Cqrs.Akka.Commands.ConcurrentAkkaCommandPublisher< TAuthenticationToken, TTarget > | |