akka.persistence.journal
Class JournalPerfSpec.BenchActor

java.lang.Object
  akka.persistence.journal.JournalPerfSpec.BenchActor

All Implemented Interfaces:

Actor, ActorLogging, Stash, StashFactory, StashSupport, UnrestrictedStash, RequiresMessageQueue<DequeBasedMessageQueueSemantics>, Eventsourced, PersistentActor, ProcessorImpl, Recovery, Snapshotter

Enclosing interface:

JournalPerfSpec

public static class JournalPerfSpec.BenchActor
extends java.lang.Object
implements PersistentActor, ActorLogging

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

JournalPerfSpec.BenchActor

public JournalPerfSpec.BenchActor(java.lang.String persistenceId,
                                  ActorRef replyTo,
                                  int replyAfter)

Method Detail

persistenceId

public java.lang.String persistenceId()

Description copied from interface: Recovery

Id of the persistent entity for which messages should be replayed.

Specified by:

persistenceId in interface Recovery

Returns:

(undocumented)

counter

public int counter()

receiveCommand

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveCommand()

Specified by:

receiveCommand in interface Eventsourced

receiveRecover

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveRecover()

Specified by:

receiveRecover in interface Eventsourced