Class AkkaCommandBusProxy<TAuthenticationToken>.BusActor
Similar to a ICommandPublisher<TAuthenticationToken>, passes commands onto the CommandHandlerResolver.
Inheritance
System.Object
Akka.Actor.ActorBase
Akka.Actor.UntypedActor
Akka.Actor.ReceiveActor
AkkaCommandBusProxy<TAuthenticationToken>.BusActor
Inherited Members
Akka.Actor.ReceiveActor.Akka.Actor.Internal.IInitializableActor.Init()
Akka.Actor.ReceiveActor.OnReceive(System.Object)
Akka.Actor.ReceiveActor.Become(System.Action)
Akka.Actor.ReceiveActor.BecomeStacked(System.Action)
Akka.Actor.ReceiveActor.Become(System.Action, System.Boolean)
Akka.Actor.ReceiveActor.Receive<T>(System.Func<T, System.Threading.Tasks.Task>)
Akka.Actor.ReceiveActor.Receive<T>(System.Action<T>, System.Predicate<T>)
Akka.Actor.ReceiveActor.Receive<T>(System.Predicate<T>, System.Action<T>)
Akka.Actor.ReceiveActor.Receive(System.Type, System.Action<System.Object>, System.Predicate<System.Object>)
Akka.Actor.ReceiveActor.Receive(System.Type, System.Predicate<System.Object>, System.Action<System.Object>)
Akka.Actor.ReceiveActor.Receive<T>(System.Func<T, System.Boolean>)
Akka.Actor.ReceiveActor.Receive(System.Type, System.Func<System.Object, System.Boolean>)
Akka.Actor.ReceiveActor.ReceiveAny(System.Action<System.Object>)
Akka.Actor.UntypedActor.Receive(System.Object)
Akka.Actor.UntypedActor.RunTask(System.Action)
Akka.Actor.UntypedActor.RunTask(System.Func<System.Threading.Tasks.Task>)
Akka.Actor.UntypedActor.Become(Akka.Actor.UntypedReceive, System.Boolean)
Akka.Actor.UntypedActor.Become(Akka.Actor.UntypedReceive)
Akka.Actor.UntypedActor.BecomeStacked(Akka.Actor.UntypedReceive)
Akka.Actor.UntypedActor.Context
Akka.Actor.ActorBase.AroundReceive(Akka.Actor.Receive, System.Object)
Akka.Actor.ActorBase.Unhandled(System.Object)
Akka.Actor.ActorBase.Become(Akka.Actor.Receive, System.Boolean)
Akka.Actor.ActorBase.Become(Akka.Actor.Receive)
Akka.Actor.ActorBase.BecomeStacked(Akka.Actor.Receive)
Akka.Actor.ActorBase.UnbecomeStacked()
Akka.Actor.ActorBase.Unbecome()
Akka.Actor.ActorBase.SetReceiveTimeout(System.Nullable<System.TimeSpan>)
Akka.Actor.ActorBase.SupervisorStrategy()
Akka.Actor.ActorBase.AroundPreRestart(System.Exception, System.Object)
Akka.Actor.ActorBase.AroundPreStart()
Akka.Actor.ActorBase.PreStart()
Akka.Actor.ActorBase.AroundPostRestart(System.Exception, System.Object)
Akka.Actor.ActorBase.PreRestart(System.Exception, System.Object)
Akka.Actor.ActorBase.PostRestart(System.Exception)
Akka.Actor.ActorBase.AroundPostStop()
Akka.Actor.ActorBase.PostStop()
Akka.Actor.ActorBase.Sender
Akka.Actor.ActorBase.Self
Akka.Actor.ActorBase.Akka.Actor.IInternalActor.ActorContext
Akka.Actor.ActorBase.EmptyReceive
System.Object.ToString()
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
Namespace: Cqrs.Akka.Commands
Assembly: Cqrs.Akka.dll
Syntax
public class BusActor : ReceiveActor, IInternalActor, IInitializableActor
Constructors
BusActor(IAkkaCommandPublisher<TAuthenticationToken>, ICorrelationIdHelper, IAuthenticationTokenHelper<TAuthenticationToken>)
Instantiates a new instance of AkkaCommandBusProxy<TAuthenticationToken>.BusActor.
Declaration
public BusActor(IAkkaCommandPublisher<TAuthenticationToken> commandHandlerResolver, ICorrelationIdHelper correlationIdHelper, IAuthenticationTokenHelper<TAuthenticationToken> authenticationTokenHelper)
Parameters
Type | Name | Description |
---|---|---|
IAkkaCommandPublisher<TAuthenticationToken> | commandHandlerResolver | |
cdmdotnet.Logging.ICorrelationIdHelper | correlationIdHelper | |
IAuthenticationTokenHelper<TAuthenticationToken> | authenticationTokenHelper |
Properties
AuthenticationTokenHelper
Gets or sets the IAuthenticationTokenHelper<TAuthenticationToken>.
Declaration
protected IAuthenticationTokenHelper<TAuthenticationToken> AuthenticationTokenHelper { get; }
Property Value
Type | Description |
---|---|
IAuthenticationTokenHelper<TAuthenticationToken> |
CommandHandlerResolver
Gets or sets the IAkkaCommandPublisher<TAuthenticationToken>.
Declaration
protected IAkkaCommandPublisher<TAuthenticationToken> CommandHandlerResolver { get; }
Property Value
Type | Description |
---|---|
IAkkaCommandPublisher<TAuthenticationToken> |
CorrelationIdHelper
Gets or sets the cdmdotnet.Logging.ICorrelationIdHelper.
Declaration
protected ICorrelationIdHelper CorrelationIdHelper { get; }
Property Value
Type | Description |
---|---|
cdmdotnet.Logging.ICorrelationIdHelper |
Methods
ExecuteReceive(ICommand<TAuthenticationToken>)
Passes the provided command
to CommandHandlerResolver via Publish<TCommand>(TCommand)
then calls Akka.Actor.ActorRefImplicitSenderExtensions.Tell(Akka.Actor.IActorRef,System.Object).
Declaration
protected virtual void ExecuteReceive(ICommand<TAuthenticationToken> command)
Parameters
Type | Name | Description |
---|---|---|
ICommand<TAuthenticationToken> | command |