Class AkkaAggregateRepository<TAuthenticationToken>
A AggregateRepository<TAuthenticationToken> that is safe to use within Akka.NET
Inheritance
System.Object
AggregateRepository<TAuthenticationToken>
AkkaAggregateRepository<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 AkkaAggregateRepository<TAuthenticationToken> : AggregateRepository<TAuthenticationToken>, IAkkaAggregateRepository<TAuthenticationToken>, IAggregateRepository<TAuthenticationToken>
Type Parameters
Name | Description |
---|---|
TAuthenticationToken | The System.Type of authentication token. |
Constructors
AkkaAggregateRepository(IAggregateFactory, IEventStore<TAuthenticationToken>, IEventPublisher<TAuthenticationToken>, ICorrelationIdHelper, IAkkaEventPublisherProxy<TAuthenticationToken>)
Instantiates a new instance of AkkaAggregateRepository<TAuthenticationToken>
Declaration
public AkkaAggregateRepository(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
CreateAggregate<TAggregateRoot>(Guid)
Calls Create(Type, Nullable<Guid>, Boolean) to get a, TAggregateRoot
.
Declaration
protected override TAggregateRoot CreateAggregate<TAggregateRoot>(Guid id)where TAggregateRoot : IAggregateRoot<TAuthenticationToken>
Parameters
Type | Name | Description |
---|---|---|
System.Guid | id | The id of the |
Returns
Type | Description |
---|---|
TAggregateRoot |
Type Parameters
Name | Description |
---|---|
TAggregateRoot | The System.Type of IAggregateRoot<TAuthenticationToken>. |
Overrides
Cqrs.Domain.AggregateRepository<TAuthenticationToken>.CreateAggregate<TAggregateRoot>(System.Guid)
PublishEvent(IEvent<TAuthenticationToken>)
Publish the saved event
asynchronously on EventPublisher,
then calls PublishEvent(IEvent<TAuthenticationToken>)
Declaration
protected override void PublishEvent(IEvent<TAuthenticationToken> event)
Parameters
Type | Name | Description |
---|---|---|
IEvent<TAuthenticationToken> | event |
Overrides
Cqrs.Domain.AggregateRepository<TAuthenticationToken>.PublishEvent(Cqrs.Events.IEvent<TAuthenticationToken>)