|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.persistence.RequestReader
public class RequestReader
Reads Deliver
requests from the journal and processes them. The number of Deliver
requests
processed per iteration depends on
- pendingConfirmationsMax
parameter in PersistentChannelSettings
- pendingConfirmationsMin
parameter in PersistentChannelSettings
and the
- current number of pending confirmations.
PersistentChannel
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface akka.persistence.Recovery |
---|
Recovery.State |
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Constructor Summary | |
---|---|
RequestReader(java.lang.String channelId,
PersistentChannelSettings channelSettings)
|
Method Summary | |
---|---|
void |
onReplayFailure(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
boolean await,
java.lang.Throwable cause)
INTERNAL API. |
void |
onReplaySuccess(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
boolean await)
INTERNAL API. |
java.lang.String |
persistenceId()
Id of the persistent entity for which messages should be replayed. |
void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
User overridable callback: '''By default it disposes of all children and then calls postStop() .''' |
void |
preStart()
User overridable callback. |
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. |
java.lang.String |
snapshotterId()
Snapshotter id. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.persistence.Recovery |
---|
_currentPersistent, _currentState, _lastSequenceNr, _recoveryFailureCause, _recoveryFailureMessage, aroundReceive, currentPersistentMessage, extension, getCurrentPersistentMessage, journal, lastSequenceNr, prepareRestart, processorId, receiverStash, recoveryPending, recoveryStarted, replayFailed, replayStarted, runReceive, snapshotSequenceNr, updateLastSequenceNr, updateLastSequenceNr, withCurrentPersistent |
Methods inherited from interface akka.persistence.Snapshotter |
---|
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot, snapshotStore |
Methods inherited from interface akka.actor.UnrestrictedStash |
---|
postStop |
Methods inherited from interface akka.actor.Actor |
---|
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, context, postRestart, self, sender, supervisorStrategy, unhandled |
Methods inherited from interface akka.actor.StashSupport |
---|
actorCell, capacity, clearStash, context, enqueueFirst, mailbox, prepend, self, stash, theStash, unstash, unstashAll, unstashAll |
Methods inherited from interface akka.actor.StashFactory |
---|
createStash |
Constructor Detail |
---|
public RequestReader(java.lang.String channelId, PersistentChannelSettings channelSettings)
Method Detail |
---|
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
receive
in interface Actor
public void onReplaySuccess(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, boolean await)
Recovery
Called whenever a message replay succeeds.
onReplaySuccess
in interface Recovery
receive
- the actor's current behavior.await
- awaitReplay
value of the calling replayStarted
state.public void onReplayFailure(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, boolean await, java.lang.Throwable cause)
Recovery
Called whenever a message replay fails.
onReplayFailure
in interface Recovery
receive
- the actor's current behavior.await
- awaitReplay
value of the calling replayStarted
state.cause
- failure cause.public java.lang.String persistenceId()
Recovery
persistenceId
in interface Recovery
public java.lang.String snapshotterId()
Snapshotter
snapshotterId
in interface Snapshotter
public void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
Actor
postStop()
.'''
preRestart
in interface Actor
preRestart
in interface UnrestrictedStash
reason
- the Throwable that caused the restart to happenmessage
- optionally the current message the actor processed when failing, if applicable
Is called on a crashed Actor right BEFORE it is restarted to allow clean
up of resources before Actor is terminated.public void preStart()
Actor
preStart
in interface Actor
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |