| AsyncWriteProxyReplayMessagesAsync Method |
TBD
Namespace:
Akka.Persistence.Journal
Assembly:
Akka.Persistence (in Akka.Persistence.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax public override Task ReplayMessagesAsync(
IActorContext context,
string persistenceId,
long fromSequenceNr,
long toSequenceNr,
long max,
Action<IPersistentRepresentation> recoveryCallback
)
abstract ReplayMessagesAsync :
context : IActorContext *
persistenceId : string *
fromSequenceNr : int64 *
toSequenceNr : int64 *
max : int64 *
recoveryCallback : Action<IPersistentRepresentation> -> Task
override ReplayMessagesAsync :
context : IActorContext *
persistenceId : string *
fromSequenceNr : int64 *
toSequenceNr : int64 *
max : int64 *
recoveryCallback : Action<IPersistentRepresentation> -> Task
Parameters
- context
- Type: Akka.ActorIActorContext
TBD - persistenceId
- Type: SystemString
TBD - fromSequenceNr
- Type: SystemInt64
TBD - toSequenceNr
- Type: SystemInt64
TBD - max
- Type: SystemInt64
TBD - recoveryCallback
- Type: SystemActionIPersistentRepresentation
TBD
Return Value
Type:
TaskTBD
Implements
IAsyncRecoveryReplayMessagesAsync(IActorContext, String, Int64, Int64, Int64, ActionIPersistentRepresentation)Exceptions Exception | Condition |
---|
TimeoutException |
This exception is thrown when the store has not been initialized.
|
See Also