Class AkkaEventBusProxy<TAuthenticationToken>
A IEventPublisher<TAuthenticationToken> that proxies IEvent<TAuthenticationToken> to the Akka.Actor.IActorRef which acts as a single point of all handler resolutions.
Inheritance
System.Object
AkkaEventBusProxy<TAuthenticationToken>
Inherited Members
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.Events
Assembly: Cqrs.Akka.dll
Syntax
public class AkkaEventBusProxy<TAuthenticationToken> : IAkkaEventPublisherProxy<TAuthenticationToken>, IEventPublisher<TAuthenticationToken>
Type Parameters
Name | Description |
---|---|
TAuthenticationToken |
Constructors
AkkaEventBusProxy(IDependencyResolver, ICorrelationIdHelper, IAuthenticationTokenHelper<TAuthenticationToken>)
Instantiates a new instance of AkkaEventBusProxy<TAuthenticationToken>.
Declaration
public AkkaEventBusProxy(IDependencyResolver dependencyResolver, ICorrelationIdHelper correlationIdHelper, IAuthenticationTokenHelper<TAuthenticationToken> authenticationTokenHelper)
Parameters
Type | Name | Description |
---|---|---|
IDependencyResolver | dependencyResolver | |
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> |
CorrelationIdHelper
Gets or sets the cdmdotnet.Logging.ICorrelationIdHelper.
Declaration
protected ICorrelationIdHelper CorrelationIdHelper { get; }
Property Value
Type | Description |
---|---|
cdmdotnet.Logging.ICorrelationIdHelper |
EventHandlerResolver
Gets the Akka.Actor.IActorRef that we send/proxy the event to.
Declaration
protected IActorRef EventHandlerResolver { get; }
Property Value
Type | Description |
---|---|
Akka.Actor.IActorRef |
Methods
Publish<TEvent>(TEvent)
Publishes the provided event
on the event bus.
Declaration
public virtual void Publish<TEvent>(TEvent event)where TEvent : IEvent<TAuthenticationToken>
Parameters
Type | Name | Description |
---|---|---|
TEvent | event |
Type Parameters
Name | Description |
---|---|
TEvent |
Implements
Publish<TEvent>(IEnumerable<TEvent>)
Publishes the provided events
on the event bus.
Declaration
public virtual void Publish<TEvent>(IEnumerable<TEvent> events)where TEvent : IEvent<TAuthenticationToken>
Parameters
Type | Name | Description |
---|---|---|
System.Collections.Generic.IEnumerable<TEvent> | events |
Type Parameters
Name | Description |
---|---|
TEvent |