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>

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

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)

TBD

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

TBD
long toSequenceNr

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

ReadHighestSequenceNrAsync(string, long)

TBD

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

TBD
long fromSequenceNr

TBD
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>)

TBD

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

TBD
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