|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ProcessorImpl
INTERNAL API
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$ |
Method Summary | |
---|---|
java.lang.String |
_persistenceId()
|
void |
aroundPostStop()
INTERNAL API. |
void |
aroundPreRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
INTERNAL API. |
void |
aroundPreStart()
INTERNAL API. |
void |
deleteMessage(long sequenceNr)
Marks a persistent message, identified by sequenceNr , as deleted. |
void |
deleteMessage(long sequenceNr,
boolean permanent)
Deletes a persistent message identified by sequenceNr . |
void |
deleteMessages(long toSequenceNr)
Permanently deletes all persistent messages with sequence numbers less than or equal toSequenceNr . |
void |
deleteMessages(long toSequenceNr,
boolean permanent)
Deletes all persistent messages with sequence numbers less than or equal toSequenceNr . |
void |
flushJournalBatch()
INTERNAL API |
java.lang.Object |
initializing()
Processes the highest stored sequence number response from the journal and then switches to processing state. |
int |
instanceId()
|
long |
nextSequenceNr()
|
void |
onRecoveryCompleted(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive)
Invokes this processor's behavior with a RecoveryFinished message. |
void |
onRecoveryFailure(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Throwable cause)
Invokes this processor's behavior with a RecoveryFailure message. |
void |
onReplayFailure(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
boolean awaitReplay,
java.lang.Throwable cause)
INTERNAL API. |
void |
onReplaySuccess(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
boolean awaitReplay)
INTERNAL API. |
void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
User-overridable callback. |
void |
preRestartDefault(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
Calls preRestart and then super.preRestart() . |
void |
preStart()
User-overridable callback. |
java.lang.Object |
processing()
Journals and processes new messages, both persistent and transient. |
scala.collection.immutable.Vector<Resequenceable> |
processorBatch()
|
java.lang.String |
processorId()
Processor id. |
boolean |
recoveryFinished()
Returns true if this processor has successfully finished recovery. |
boolean |
recoveryRunning()
Returns true if this processor is currently recovering. |
long |
sequenceNr()
|
java.lang.String |
snapshotterId()
Returns persistenceId . |
void |
unhandled(java.lang.Object message)
User overridable callback. |
scala.Function1<java.lang.Object,java.lang.Object> |
unstashFilterPredicate()
|
Methods inherited from interface akka.persistence.Recovery |
---|
_currentPersistent, _currentState, _lastSequenceNr, _recoveryFailureCause, _recoveryFailureMessage, aroundReceive, currentPersistentMessage, extension, getCurrentPersistentMessage, journal, lastSequenceNr, persistenceId, prepareRestart, 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, context, postRestart, receive, self, sender, supervisorStrategy |
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 |
Method Detail |
---|
int instanceId()
java.lang.Object initializing()
processing
state.
java.lang.Object processing()
void onReplaySuccess(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, boolean awaitReplay)
Switches to initializing
state and requests the highest stored sequence number from the journal.
onReplaySuccess
in interface Recovery
receive
- (undocumented)awaitReplay
- (undocumented)void onReplayFailure(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, boolean awaitReplay, java.lang.Throwable cause)
onReplayFailure
in interface Recovery
receive
- (undocumented)awaitReplay
- (undocumented)cause
- (undocumented)void onRecoveryFailure(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Throwable cause)
RecoveryFailure
message.
receive
- (undocumented)cause
- (undocumented)void onRecoveryCompleted(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive)
RecoveryFinished
message.
receive
- (undocumented)java.lang.String _persistenceId()
scala.collection.immutable.Vector<Resequenceable> processorBatch()
long sequenceNr()
java.lang.String processorId()
processorId
in interface Recovery
java.lang.String snapshotterId()
persistenceId
.
snapshotterId
in interface Snapshotter
boolean recoveryRunning()
true
if this processor is currently recovering.
boolean recoveryFinished()
true
if this processor has successfully finished recovery.
void deleteMessage(long sequenceNr)
sequenceNr
, as deleted. A message marked as deleted is
not replayed during recovery. This method is usually called inside preRestartProcessor
when a
persistent message caused an exception. Processors that want to re-receive that persistent message
during recovery should not call this method.
sequenceNr
- sequence number of the persistent message to be deleted.void deleteMessage(long sequenceNr, boolean permanent)
sequenceNr
. If permanent
is set to false
,
the persistent message is marked as deleted in the journal, otherwise it is permanently
deleted from the journal. A deleted message is not replayed during recovery. This method
is usually called inside preRestartProcessor
when a persistent message caused an exception.
Processors that want to re-receive that persistent message during recovery should not call
this method.
sequenceNr
- sequence number of the persistent message to be deleted.permanent
- if false
, the message is marked as deleted, otherwise it is permanently deleted.void deleteMessages(long toSequenceNr)
toSequenceNr
.
toSequenceNr
- upper sequence number bound of persistent messages to be deleted.void deleteMessages(long toSequenceNr, boolean permanent)
toSequenceNr
. If permanent
is set to false
, the persistent messages are marked as deleted in the journal, otherwise
they permanently deleted from the journal.
toSequenceNr
- upper sequence number bound of persistent messages to be deleted.permanent
- if false
, the message is marked as deleted, otherwise it is permanently deleted.void flushJournalBatch()
void aroundPreStart()
aroundPreStart
in interface Actor
void aroundPostStop()
aroundPostStop
in interface Actor
void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
aroundPreRestart
in interface Actor
reason
- (undocumented)message
- (undocumented)void preStart()
Recover()
to self
.
preStart
in interface Actor
void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
Recover(lastSequenceNr)
message to self
if message
is defined, Recover() otherwise
.
preRestart
in interface Actor
preRestart
in interface UnrestrictedStash
reason
- (undocumented)message
- (undocumented)void preRestartDefault(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
preRestart
and then super.preRestart()
. If processor implementation classes want to
opt out from stopping child actors, they should override this method and call preRestart
only.
reason
- (undocumented)message
- (undocumented)void unhandled(java.lang.Object message)
Actor
DeathPactException
(in
case of an unhandled Terminated
message) or publishes an UnhandledMessage
to the actor's system's EventStream
unhandled
in interface Actor
message
- (undocumented)long nextSequenceNr()
scala.Function1<java.lang.Object,java.lang.Object> unstashFilterPredicate()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |