|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectakka.persistence.journal.JournalPerfSpec.BenchActor
public static class JournalPerfSpec.BenchActor
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface akka.persistence.Eventsourced |
---|
Eventsourced.PendingHandlerInvocation |
Nested classes/interfaces inherited from interface akka.persistence.Recovery |
---|
Recovery.State |
Nested classes/interfaces inherited from interface akka.actor.Actor |
---|
Actor.emptyBehavior$ |
Constructor Summary | |
---|---|
JournalPerfSpec.BenchActor(java.lang.String persistenceId,
ActorRef replyTo,
int replyAfter)
|
Method Summary | |
---|---|
int |
counter()
|
java.lang.String |
persistenceId()
Id of the persistent entity for which messages should be replayed. |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveCommand()
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveRecover()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.persistence.PersistentActor |
---|
receive |
Methods inherited from interface akka.persistence.Eventsourced |
---|
aroundPreRestart, aroundReceive, currentState, defer, defer, flushBatch, initialBehavior, pendingInvocations, pendingStashingPersistInvocations, persist, persist, persistAsync, persistAsync, persistingEvents, postStop, preRestart, processingCommands, processorStash, recovering, recoveryBehavior, resequenceableEventBatch, unstashAll, 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, 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, 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 |
Methods inherited from interface akka.actor.ActorLogging |
---|
_log, log |
Constructor Detail |
---|
public JournalPerfSpec.BenchActor(java.lang.String persistenceId, ActorRef replyTo, int replyAfter)
Method Detail |
---|
public java.lang.String persistenceId()
Recovery
persistenceId
in interface Recovery
public int counter()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveCommand()
receiveCommand
in interface Eventsourced
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveRecover()
receiveRecover
in interface Eventsourced
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |