![]() |
CQRS.NET
4.0
A lightweight enterprise Function as a Service (FaaS) framework to write function based serverless and micro-service applications in hybrid multi-datacentre, on-premise and Azure environments.
|
An IEventPublisher<TAuthenticationToken> that proxies IEvent<TAuthenticationToken> back onto the IActorRef and then publishes the IEvent<TAuthenticationToken> on the public event bus. More...
Public Member Functions | |
AkkaEventBus (IBusHelper busHelper, IAuthenticationTokenHelper< TAuthenticationToken > authenticationTokenHelper, ICorrelationIdHelper correlationIdHelper, ILogger logger, IEventPublisher< TAuthenticationToken > eventPublisher, IEventReceiver< TAuthenticationToken > eventReceiver) | |
Instantiates a new instance of AkkaEventBus<TAuthenticationToken> More... | |
void | Publish< TEvent > (TEvent @event) |
Publishes the provided event on the event bus. More... | |
virtual void | Publish< TEvent > (IEnumerable< TEvent > events) |
Publishes the provided events on the event bus. More... | |
virtual void | PrepareEvent< TEvent > (TEvent @event, string framework) |
Prepares an IEvent<TAuthenticationToken> to be sent specifying the framework it is sent via. More... | |
virtual bool | PrepareAndValidateEvent< TEvent > (TEvent @event, string framework, out IEnumerable< RouteHandlerDelegate > handlers) |
Prepares and validates an IEvent<TAuthenticationToken> to be sent specifying the framework it is sent via. More... | |
void | RegisterHandler< TMessage > (Action< TMessage > handler, Type targetedType, bool holdMessageLock=true) |
Register an event or command handler that will listen and respond to events or commands. More... | |
void | RegisterHandler< TMessage > (Action< TMessage > handler, bool holdMessageLock=true) |
Register an event or command handler that will listen and respond to events or commands. More... | |
void | RegisterGlobalEventHandler< TMessage > (Action< TMessage > handler, bool holdMessageLock=true) |
Register an event handler that will listen and respond to all events. More... | |
Properties | |
static RouteManager | Routes [get] |
Gets the RouteManager More... | |
IAuthenticationTokenHelper< TAuthenticationToken > | AuthenticationTokenHelper [get] |
Gets or sets the Authentication Token Helper More... | |
ICorrelationIdHelper | CorrelationIdHelper [get] |
Gets or sets the ICorrelationIdHelper More... | |
IBusHelper | BusHelper [get] |
Gets or sets the IBusHelper More... | |
ILogger | Logger [get] |
Gets or sets the ILogger More... | |
IEventPublisher< TAuthenticationToken > | EventPublisher [get] |
Gets or sets the IEventPublisher<TAuthenticationToken> More... | |
IEventReceiver< TAuthenticationToken > | EventReceiver [get] |
Gets or sets the IEventReceiver<TAuthenticationToken> More... | |
An IEventPublisher<TAuthenticationToken> that proxies IEvent<TAuthenticationToken> back onto the IActorRef and then publishes the IEvent<TAuthenticationToken> on the public event bus.