SagaCommandsType
PackageFCQRS
C#-friendly saga command targeting
Specification
Kind
Type
Members
8
Examples
0
ToActorSignature
SagaCommands.ToActor(actorRef, command)
ToActorAfterSignature
SagaCommands.ToActorAfter(actorRef, command, delayMs, taskName)
ToAggregateSignature
SagaCommands.ToAggregate(factory, aggregateId, command)
ToAggregateAfterSignature
SagaCommands.ToAggregateAfter(factory, entityId, command, delayMs, taskName)
ToOriginatorSignature
SagaCommands.ToOriginator(factory, command)
Summary
| Name | Signature | Synopsis |
|---|---|---|
| ToActor | SagaCommands.ToActor(actorRef, command) | Create a command to send to an actor ref |
| ToActorAfter | SagaCommands.ToActorAfter(actorRef, command, delayMs, taskName) | Create a delayed command to a concrete actor ref. |
| ToAggregate | SagaCommands.ToAggregate(factory, aggregateId, command) | Create a command to send to a named aggregate |
| ToAggregateAfter | SagaCommands.ToAggregateAfter(factory, entityId, command, delayMs, taskName) | Create a delayed command to a specific aggregate instance. |
| ToOriginator | SagaCommands.ToOriginator(factory, command) | Create a command to send to the originator aggregate |
| ToOriginatorAfter | SagaCommands.ToOriginatorAfter(factory, command, delayMs, taskName) | Create a delayed command |
| ToSelf | SagaCommands.ToSelf(command) | Create a command to the saga itself (raw; lands in HandleEvent), for example a timeout. |
| ToSelfAfter | SagaCommands.ToSelfAfter(command, delayMs, taskName) | Schedule a message to the saga itself after a delay, the idiomatic saga timeout. |
Create a command to send to an actor ref
Parameters
| Name | Type | Description |
|---|---|---|
| actorRef | IActorRef<obj> | |
| command | obj |
Returns
ExecuteCommand
Create a delayed command to a concrete actor ref.
Parameters
| Name | Type | Description |
|---|---|---|
| actorRef | IActorRef<obj> | |
| command | obj | |
| delayMs | int64 | |
| taskName | string |
Returns
ExecuteCommand
Create a command to send to a named aggregate
Parameters
| Name | Type | Description |
|---|---|---|
| factory | AggregateFactory | |
| aggregateId | string | |
| command | obj |
Returns
ExecuteCommand
Create a delayed command to a specific aggregate instance.
Parameters
| Name | Type | Description |
|---|---|---|
| factory | AggregateFactory | |
| entityId | string | |
| command | obj | |
| delayMs | int64 | |
| taskName | string |
Returns
ExecuteCommand
Create a command to send to the originator aggregate
Parameters
| Name | Type | Description |
|---|---|---|
| factory | AggregateFactory | |
| command | obj |
Returns
ExecuteCommand
Create a delayed command
Parameters
| Name | Type | Description |
|---|---|---|
| factory | AggregateFactory | |
| command | obj | |
| delayMs | int64 | |
| taskName | string |
Returns
ExecuteCommand
Create a command to the saga itself (raw; lands in HandleEvent), for example a timeout.
Parameters
| Name | Type | Description |
|---|---|---|
| command | obj |
Returns
ExecuteCommand