Class AsyncWriteProxy

A journal that delegates actual storage to a target actor. For testing only.

Inheritance
object
ActorBase
WriteJournalBase
AsyncWriteJournal
AsyncWriteProxy
Implements
Inherited Members
Namespace: Akka.Persistence.Journal
Assembly: Akka.Persistence.dll
Syntax
public abstract class AsyncWriteProxy : AsyncWriteJournal, IInternalActor, IAsyncRecovery, IWithUnboundedStash, IWithUnrestrictedStash, IActorStash, IRequiresMessageQueue<IUnboundedDequeBasedMessageQueueSemantics>, IWithTimers

Constructors

| Edit this page View Source

AsyncWriteProxy()

Declaration
protected AsyncWriteProxy()

Properties

| Edit this page View Source

Stash

TBD

Declaration
public IStash Stash { get; set; }
Property Value
Type Description
IStash
| Edit this page View Source

Timeout

TBD

Declaration
public abstract TimeSpan Timeout { get; }
Property Value
Type Description
TimeSpan
| Edit this page View Source

Timers

Gets or sets the TimerScheduler. This will be automatically populated by the framework in base constructor. Implement this as an auto property.

Declaration
public ITimerScheduler Timers { get; set; }
Property Value
Type Description
ITimerScheduler

Methods

| Edit this page View Source

AroundPreStart()

TBD

Declaration
public override void AroundPreStart()
Overrides
| Edit this page View Source

AroundReceive(Receive, object)

TBD

Declaration
protected override bool AroundReceive(Receive receive, object message)
Parameters
Type Name Description
Receive receive

TBD
object message

TBD
Returns
Type Description
bool

TBD
Overrides
| Edit this page View Source

DeleteMessagesToAsync(string, long, CancellationToken)

TBD

Declaration
protected override Task DeleteMessagesToAsync(string persistenceId, long toSequenceNr, CancellationToken cancellationToken)
Parameters
Type Name Description
string persistenceId

TBD
long toSequenceNr

TBD
CancellationToken cancellationToken

CancellationToken used to signal cancelled snapshot operation
Returns
Type Description
Task

TBD
Overrides
Exceptions
Type Condition
TimeoutException

This exception is thrown when the store has not been initialized.
| Edit this page View Source

ReadHighestSequenceNrAsync(string, long, CancellationToken)

TBD

Declaration
public override Task<long> ReadHighestSequenceNrAsync(string persistenceId, long fromSequenceNr, CancellationToken cancellationToken)
Parameters
Type Name Description
string persistenceId

TBD
long fromSequenceNr

TBD
CancellationToken cancellationToken

CancellationToken used to signal cancelled snapshot operation
Returns
Type Description
Task<long>

TBD
Overrides
Exceptions
Type Condition
TimeoutException

This exception is thrown when the store has not been initialized.
| Edit this page View Source

ReplayMessagesAsync(IActorContext, string, long, long, long, Action<IPersistentRepresentation>)

TBD

Declaration
public override Task ReplayMessagesAsync(IActorContext context, string persistenceId, long fromSequenceNr, long toSequenceNr, long max, Action<IPersistentRepresentation> recoveryCallback)
Parameters
Type Name Description
IActorContext context

TBD
string persistenceId

TBD
long fromSequenceNr

TBD
long toSequenceNr

TBD
long max

TBD
Action<IPersistentRepresentation> recoveryCallback

TBD
Returns
Type Description
Task

TBD
Overrides
Exceptions
Type Condition
TimeoutException

This exception is thrown when the store has not been initialized.
| Edit this page View Source

WriteMessagesAsync(IEnumerable<AtomicWrite>, CancellationToken)

TBD

Declaration
protected override Task<IImmutableList<Exception>> WriteMessagesAsync(IEnumerable<AtomicWrite> messages, CancellationToken cancellationToken)
Parameters
Type Name Description
IEnumerable<AtomicWrite> messages

TBD
CancellationToken cancellationToken

CancellationToken used to signal cancelled snapshot operation
Returns
Type Description
Task<IImmutableList<Exception>>

TBD
Overrides
Exceptions
Type Condition
TimeoutException

This exception is thrown when the store has not been initialized.

Implements

Extension Methods