Click or drag to resize
Akka.NETAsyncWriteJournalReplayMessagesAsync Method
Asynchronously replays persistent messages. Implementations replay a message by calling recoveryCallback. The returned task must be completed when all messages (matching the sequence number bounds) have been replayed. The task must be completed with a failure if any of the persistent messages could not be replayed. The toSequenceNr is the lowest of what was returned by ReadHighestSequenceNrAsync(String, Int64) and what the user specified as recovery Recovery parameter. This does imply that this call is always preceded by reading the highest sequence number for the given persistenceId. This call is NOT protected with a circuit-breaker because it may take a long time to replay all events. The plugin implementation itself must protect against an unresponsive backend store and make sure that the returned Task is completed with success or failure within reasonable time. It is not allowed to ignore completing the Task.

Namespace:  Akka.Persistence.Journal
Assembly:  Akka.Persistence (in Akka.Persistence.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax
public abstract Task ReplayMessagesAsync(
	IActorContext context,
	string persistenceId,
	long fromSequenceNr,
	long toSequenceNr,
	long max,
	Action<IPersistentRepresentation> recoveryCallback
)

Parameters

context
Type: Akka.ActorIActorContext
The contextual information about the actor processing replayed messages.
persistenceId
Type: SystemString
Persistent actor identifier
fromSequenceNr
Type: SystemInt64
Inclusive sequence number where replay should start
toSequenceNr
Type: SystemInt64
Inclusive sequence number where replay should end
max
Type: SystemInt64
Maximum number of messages to be replayed
recoveryCallback
Type: SystemActionIPersistentRepresentation
Called to replay a message, may be called from any thread.

Return Value

Type: Task
TBD

Implements

IAsyncRecoveryReplayMessagesAsync(IActorContext, String, Int64, Int64, Int64, ActionIPersistentRepresentation)
See Also