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.
Public Member Functions | Protected Member Functions | Properties | List of all members
Cqrs.EventStore.Bus.EventStoreEventPublisher< TAuthenticationToken > Class Template Reference

A IEventPublisher<TAuthenticationToken> that uses Greg Young's Event Store. More...

+ Inheritance diagram for Cqrs.EventStore.Bus.EventStoreEventPublisher< TAuthenticationToken >:

Public Member Functions

 EventStoreEventPublisher (IEventStoreConnectionHelper eventStoreConnectionHelper, IStoreLastEventProcessed lastEventProcessedStore)
 Instantiates a new instance of EventStoreEventPublisher<TAuthenticationToken> More...
 
void Publish< TEvent > (TEvent @event)
 Publishes the provided event on the event bus. More...
 
void Publish< TEvent > (IEnumerable< TEvent > events)
 Publishes the provided events on the event bus. More...
 

Protected Member Functions

void InitialiseCatchUpSubscription ()
 Reads the position the store was last within the stream and subscribes requesting all events prior to that position aren't replayed. More...
 

Properties

Dictionary< Type, List< Action< IMessage > > > Routes [get]
 The actions to execute per Type More...
 
IEventStoreConnection EventStoreConnection [get]
 The IEventStoreConnection used to read and write streams in the Greg Young Event Store. More...
 
IStoreLastEventProcessed LastEventProcessedStore [get]
 The store that hold stream position information. More...
 

Detailed Description

A IEventPublisher<TAuthenticationToken> that uses Greg Young's Event Store.

Template Parameters
TAuthenticationTokenThe Type of the authentication token.