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

| Improve this Doc View Source

AsyncWriteProxy()

Declaration
protected AsyncWriteProxy()

Properties

| Improve this Doc View Source

Stash

TBD

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

Timeout

TBD

Declaration
public abstract TimeSpan Timeout { get; }
Property Value
Type Description
TimeSpan

Methods

| Improve this Doc View Source

AroundPreStart()

TBD

Declaration
public override void AroundPreStart()
Overrides
| Improve this Doc 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
Boolean

TBD
Overrides
| Improve this Doc View Source

DeleteMessagesToAsync(String, Int64)

TBD

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

TBD
Int64 toSequenceNr

TBD
Returns
Type Description
Task

TBD
Overrides
Exceptions
Type Condition
TimeoutException

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

ReadHighestSequenceNrAsync(String, Int64)

TBD

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

TBD
Int64 fromSequenceNr

TBD
Returns
Type Description
Task<Int64>

TBD
Overrides
Exceptions
Type Condition
TimeoutException

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

ReplayMessagesAsync(IActorContext, String, Int64, Int64, Int64, 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
Int64 fromSequenceNr

TBD
Int64 toSequenceNr

TBD
Int64 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.
| Improve this Doc 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<System.Collections.Immutable.IImmutableList<Exception>>

TBD
Overrides
Exceptions
Type Condition
TimeoutException

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

Implements

Extension Methods