|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface Eventsourced
INTERNAL API.
Event sourcing mixin for a Processor
.
Nested Class Summary | |
---|---|
private static class |
Eventsourced.AsyncHandlerInvocation
|
static interface |
Eventsourced.PendingHandlerInvocation
|
private static class |
Eventsourced.StashingHandlerInvocation
|
Nested classes/interfaces inherited from interface akka.persistence.Recovery |
---|
Recovery.State |
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Method Summary | ||
---|---|---|
void |
aroundPreRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
INTERNAL API. |
|
void |
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object message)
INTERNAL API. |
|
Recovery.State |
currentState()
|
|
|
defer(A event,
scala.Function1<A,scala.runtime.BoxedUnit> handler)
|
|
|
defer(scala.collection.immutable.Seq<A> events,
scala.Function1<A,scala.runtime.BoxedUnit> handler)
|
|
void |
flushBatch()
|
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
initialBehavior()
INTERNAL API. |
|
java.util.LinkedList<Eventsourced.PendingHandlerInvocation> |
pendingInvocations()
|
|
long |
pendingStashingPersistInvocations()
|
|
|
persist(A event,
scala.Function1<A,scala.runtime.BoxedUnit> handler)
|
|
|
persist(scala.collection.immutable.Seq<A> events,
scala.Function1<A,scala.runtime.BoxedUnit> handler)
|
|
|
persistAsync(A event,
scala.Function1<A,scala.runtime.BoxedUnit> handler)
|
|
|
persistAsync(scala.collection.immutable.Seq<A> events,
scala.Function1<A,scala.runtime.BoxedUnit> handler)
|
|
Recovery.State |
persistingEvents()
Event persisting state. |
|
void |
postStop()
User overridable callback. |
|
void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
User-overridable callback. |
|
Recovery.State |
processingCommands()
Command processing state. |
|
StashSupport |
processorStash()
|
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveCommand()
|
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveRecover()
|
|
Recovery.State |
recovering()
Processor recovery state. |
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
recoveryBehavior()
INTERNAL API. |
|
scala.collection.immutable.List<Resequenceable> |
resequenceableEventBatch()
|
|
void |
unstashAll()
Prepends all messages in the stash to the mailbox, and then clears the stash. |
|
boolean |
useProcessorBatching()
|
Methods inherited from interface akka.persistence.ProcessorImpl |
---|
_persistenceId, aroundPostStop, aroundPreStart, deleteMessage, deleteMessage, deleteMessages, deleteMessages, flushJournalBatch, initializing, instanceId, nextSequenceNr, onRecoveryCompleted, onRecoveryFailure, onReplayFailure, onReplaySuccess, preRestartDefault, preStart, processing, processorBatch, processorId, recoveryFinished, recoveryRunning, sequenceNr, snapshotterId, unhandled, unstashFilterPredicate |
Methods inherited from interface akka.persistence.Recovery |
---|
_currentPersistent, _currentState, _lastSequenceNr, _recoveryFailureCause, _recoveryFailureMessage, 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.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 |
Methods inherited from interface akka.actor.StashFactory |
---|
createStash |
Method Detail |
---|
Recovery.State recovering()
processingCommands
Recovery.State processingCommands()
persistingEvents
.
There's no need to loop commands though the journal any more i.e. they can now be
directly offered as LoopSuccess
to the state machine implemented by Processor
.
Recovery.State persistingEvents()
processingCommands
. Only events to be persisted are processed. All other
messages are stashed internally.
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> recoveryBehavior()
This is a def and not a val because of binary compatibility in 2.3.x. It is cached where it is used.
long pendingStashingPersistInvocations()
java.util.LinkedList<Eventsourced.PendingHandlerInvocation> pendingInvocations()
scala.collection.immutable.List<Resequenceable> resequenceableEventBatch()
boolean useProcessorBatching()
Recovery.State currentState()
StashSupport processorStash()
void flushBatch()
<A> void persist(A event, scala.Function1<A,scala.runtime.BoxedUnit> handler)
<A> void persist(scala.collection.immutable.Seq<A> events, scala.Function1<A,scala.runtime.BoxedUnit> handler)
<A> void persistAsync(A event, scala.Function1<A,scala.runtime.BoxedUnit> handler)
<A> void persistAsync(scala.collection.immutable.Seq<A> events, scala.Function1<A,scala.runtime.BoxedUnit> handler)
<A> void defer(A event, scala.Function1<A,scala.runtime.BoxedUnit> handler)
<A> void defer(scala.collection.immutable.Seq<A> events, scala.Function1<A,scala.runtime.BoxedUnit> handler)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveRecover()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveCommand()
void unstashAll()
StashSupport
Messages from the stash are enqueued to the mailbox until the capacity of the
mailbox (if any) has been reached. In case a bounded mailbox overflows, a
MessageQueueAppendFailedException
is thrown.
The stash is guaranteed to be empty after calling unstashAll()
.
unstashAll
in interface StashSupport
void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object message)
Actor
Can be overridden to intercept calls to this actor's current behavior.
aroundReceive
in interface Actor
aroundReceive
in interface Recovery
receive
- current behavior.message
- current message.void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
ProcessorImpl
aroundPreRestart
in interface Actor
aroundPreRestart
in interface ProcessorImpl
reason
- (undocumented)message
- (undocumented)void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
ProcessorImpl
Recover(lastSequenceNr)
message to self
if message
is defined, Recover() otherwise
.
preRestart
in interface Actor
preRestart
in interface ProcessorImpl
preRestart
in interface UnrestrictedStash
reason
- (undocumented)message
- (undocumented)void postStop()
Actor
postStop
in interface Actor
postStop
in interface UnrestrictedStash
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> initialBehavior()
Only here for binary compatibility in 2.3.x.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |