Class AkkaSagaRepository<TAuthenticationToken>
A SagaRepository<TAuthenticationToken> that is safe to use within Akka.NET
Inheritance
System.Object
SagaRepository<TAuthenticationToken>
AkkaSagaRepository<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.Domain
Assembly: Cqrs.Akka.dll
Syntax
public class AkkaSagaRepository<TAuthenticationToken> : SagaRepository<TAuthenticationToken>, IAkkaSagaRepository<TAuthenticationToken>, ISagaRepository<TAuthenticationToken>
Type Parameters
Name | Description |
---|---|
TAuthenticationToken | The System.Type of authentication token. |
Constructors
AkkaSagaRepository(IAggregateFactory, IEventStore<TAuthenticationToken>, IEventPublisher<TAuthenticationToken>, ICorrelationIdHelper, IAkkaEventPublisherProxy<TAuthenticationToken>)
Instantiates a new instance of AkkaSagaRepository<TAuthenticationToken>
Declaration
public AkkaSagaRepository(IAggregateFactory aggregateFactory, IEventStore<TAuthenticationToken> eventStore, IEventPublisher<TAuthenticationToken> publisher, ICorrelationIdHelper correlationIdHelper, IAkkaEventPublisherProxy<TAuthenticationToken> eventPublisher)
Parameters
Type | Name | Description |
---|---|---|
IAggregateFactory | aggregateFactory | |
IEventStore<TAuthenticationToken> | eventStore | |
IEventPublisher<TAuthenticationToken> | publisher | |
cdmdotnet.Logging.ICorrelationIdHelper | correlationIdHelper | |
IAkkaEventPublisherProxy<TAuthenticationToken> | eventPublisher |
Properties
EventPublisher
Declaration
protected IAkkaEventPublisherProxy<TAuthenticationToken> EventPublisher { get; }
Property Value
Type | Description |
---|---|
IAkkaEventPublisherProxy<TAuthenticationToken> |
Methods
CreateSaga<TSaga>(Guid)
Calls Create(Type, Nullable<Guid>, Boolean) to get a, TSaga
.
Declaration
protected override TSaga CreateSaga<TSaga>(Guid id)where TSaga : ISaga<TAuthenticationToken>
Parameters
Type | Name | Description |
---|---|---|
System.Guid | id | The id of the |
Returns
Type | Description |
---|---|
TSaga |
Type Parameters
Name | Description |
---|---|
TSaga | The System.Type of ISaga<TAuthenticationToken>. |
Overrides
Cqrs.Domain.SagaRepository<TAuthenticationToken>.CreateSaga<TSaga>(System.Guid)
PublishEvent(ISagaEvent<TAuthenticationToken>)
Publish the saved event
asynchronously on EventPublisher,
then calls PublishEvent(ISagaEvent<TAuthenticationToken>)
Declaration
protected override void PublishEvent(ISagaEvent<TAuthenticationToken> event)
Parameters
Type | Name | Description |
---|---|---|
ISagaEvent<TAuthenticationToken> | event |
Overrides
Cqrs.Domain.SagaRepository<TAuthenticationToken>.PublishEvent(Cqrs.Events.ISagaEvent<TAuthenticationToken>)