|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface AsyncWriteProxy
INTERNAL API.
A journal that delegates actual storage to a target actor. For testing only.
Nested Class Summary | |
---|---|
static class |
AsyncWriteProxy.SetStore
|
static class |
AsyncWriteProxy.SetStore$
|
Nested classes/interfaces inherited from interface akka.persistence.journal.AsyncWriteJournal |
---|
AsyncWriteJournal.Desequenced, AsyncWriteJournal.Desequenced$, AsyncWriteJournal.Resequencer |
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Method Summary | |
---|---|
scala.concurrent.Future<scala.runtime.BoxedUnit> |
asyncDeleteMessages(scala.collection.immutable.Seq<PersistentId> messageIds,
boolean permanent)
Plugin API: asynchronously deletes messages identified by messageIds from the
journal. |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
asyncDeleteMessagesTo(java.lang.String persistenceId,
long toSequenceNr,
boolean permanent)
Plugin API: asynchronously deletes all persistent messages up to toSequenceNr
(inclusive). |
scala.concurrent.Future<java.lang.Object> |
asyncReadHighestSequenceNr(java.lang.String persistenceId,
long fromSequenceNr)
Plugin API: asynchronously reads the highest stored sequence number for the given persistenceId . |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
asyncReplayMessages(java.lang.String persistenceId,
long fromSequenceNr,
long toSequenceNr,
long max,
scala.Function1<PersistentRepr,scala.runtime.BoxedUnit> replayCallback)
Plugin API: asynchronously replays persistent messages. |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
asyncWriteConfirmations(scala.collection.immutable.Seq<PersistentConfirmation> confirmations)
Plugin API: asynchronously writes a batch of delivery confirmations to the journal. |
scala.concurrent.Future<scala.runtime.BoxedUnit> |
asyncWriteMessages(scala.collection.immutable.Seq<PersistentRepr> messages)
Plugin API: asynchronously writes a batch of persistent messages to the journal. |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
initialized()
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function with the actor logic. |
ActorRef |
store()
|
Timeout |
timeout()
|
Methods inherited from interface akka.persistence.journal.AsyncWriteJournal |
---|
extension, publish, resequencer, resequencerCounter |
Methods inherited from interface akka.persistence.journal.WriteJournalBase |
---|
persistentPrepareWrite, preparePersistentBatch |
Methods inherited from interface akka.actor.UnrestrictedStash |
---|
postStop, preRestart |
Methods inherited from interface akka.actor.Actor |
---|
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preStart, self, sender, supervisorStrategy, unhandled |
Methods inherited from interface akka.actor.StashSupport |
---|
actorCell, capacity, clearStash, context, enqueueFirst, mailbox, prepend, self, stash, theStash, unstash, unstashAll, unstashAll |
Method Detail |
---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> initialized()
ActorRef store()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
receive
in interface Actor
receive
in interface AsyncWriteJournal
Timeout timeout()
scala.concurrent.Future<scala.runtime.BoxedUnit> asyncWriteMessages(scala.collection.immutable.Seq<PersistentRepr> messages)
AsyncWriteJournal
asyncWriteMessages
in interface AsyncWriteJournal
messages
- (undocumented)
scala.concurrent.Future<scala.runtime.BoxedUnit> asyncWriteConfirmations(scala.collection.immutable.Seq<PersistentConfirmation> confirmations)
AsyncWriteJournal
asyncWriteConfirmations
in interface AsyncWriteJournal
confirmations
- (undocumented)
scala.concurrent.Future<scala.runtime.BoxedUnit> asyncDeleteMessages(scala.collection.immutable.Seq<PersistentId> messageIds, boolean permanent)
AsyncWriteJournal
messageIds
from the
journal. If permanent
is set to false
, the persistent messages are marked as
deleted, otherwise they are permanently deleted.
asyncDeleteMessages
in interface AsyncWriteJournal
messageIds
- (undocumented)permanent
- (undocumented)
scala.concurrent.Future<scala.runtime.BoxedUnit> asyncDeleteMessagesTo(java.lang.String persistenceId, long toSequenceNr, boolean permanent)
AsyncWriteJournal
toSequenceNr
(inclusive). If permanent
is set to false
, the persistent messages are marked
as deleted, otherwise they are permanently deleted.
asyncDeleteMessagesTo
in interface AsyncWriteJournal
persistenceId
- (undocumented)toSequenceNr
- (undocumented)permanent
- (undocumented)
scala.concurrent.Future<scala.runtime.BoxedUnit> asyncReplayMessages(java.lang.String persistenceId, long fromSequenceNr, long toSequenceNr, long max, scala.Function1<PersistentRepr,scala.runtime.BoxedUnit> replayCallback)
AsyncRecovery
replayCallback
. The returned future must be completed
when all messages (matching the sequence number bounds) have been replayed.
The future must be completed with a failure if any of the persistent messages
could not be replayed.
The replayCallback
must also be called with messages that have been marked
as deleted. In this case a replayed message's deleted
method must return
true
.
The channel ids of delivery confirmations that are available for a replayed
message must be contained in that message's confirms
sequence.
asyncReplayMessages
in interface AsyncRecovery
persistenceId
- persistent actor id.fromSequenceNr
- sequence number where replay should start (inclusive).toSequenceNr
- sequence number where replay should end (inclusive).max
- maximum number of messages to be replayed.replayCallback
- called to replay a single message. Can be called from any
thread.
AsyncWriteJournal
,
SyncWriteJournal
scala.concurrent.Future<java.lang.Object> asyncReadHighestSequenceNr(java.lang.String persistenceId, long fromSequenceNr)
AsyncRecovery
persistenceId
.
asyncReadHighestSequenceNr
in interface AsyncRecovery
persistenceId
- persistent actor id.fromSequenceNr
- hint where to start searching for the highest sequence
number.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |