akka.persistence.multidc.testkit

Class CassandraLifecycle.AwaitPersistenceInit

java.lang.Object

akka.persistence.multidc.testkit.CassandraLifecycle.AwaitPersistenceInit

All Implemented Interfaces:

akka.actor.Actor, akka.actor.Stash, akka.actor.StashFactory, akka.actor.StashSupport, akka.actor.UnrestrictedStash, akka.dispatch.RequiresMessageQueue<akka.dispatch.DequeBasedMessageQueueSemantics>, akka.persistence.Eventsourced, akka.persistence.PersistenceIdentity, akka.persistence.PersistenceRecovery, akka.persistence.PersistenceStash, akka.persistence.PersistentActor, akka.persistence.Snapshotter

Enclosing class:

CassandraLifecycle

public static class CassandraLifecycle.AwaitPersistenceInit
extends java.lang.Object
implements akka.persistence.PersistentActor

Nested Class Summary

Nested classes/interfaces inherited from interface akka.persistence.Eventsourced

akka.persistence.Eventsourced.AsyncHandlerInvocation, akka.persistence.Eventsourced.AsyncHandlerInvocation$, akka.persistence.Eventsourced.PendingHandlerInvocation, akka.persistence.Eventsourced.ProcessingState, akka.persistence.Eventsourced.RecoveryTick, akka.persistence.Eventsourced.RecoveryTick$, akka.persistence.Eventsourced.StashingHandlerInvocation, akka.persistence.Eventsourced.StashingHandlerInvocation$, akka.persistence.Eventsourced.State

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
AwaitPersistenceInit(java.lang.String journalPluginId, java.lang.String snapshotPluginId)

Method Summary

Modifier and Type	Method and Description
protected void	akka$actor$Actor$_setter_$context_$eq(akka.actor.ActorContext x$1)
protected void	akka$actor$Actor$_setter_$self_$eq(akka.actor.ActorRef x$1)
protected void	akka$actor$StashSupport$_setter_$mailbox_$eq(akka.dispatch.DequeBasedMessageQueueSemantics x$1)
akka.actor.ActorContext	context()
protected akka.actor.ActorRef	journal()
java.lang.String	journalPluginId()
akka.dispatch.DequeBasedMessageQueueSemantics	mailbox()
java.lang.String	persistenceId()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveCommand()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveRecover()
akka.actor.ActorRef	self()
java.lang.String	snapshotPluginId()
protected akka.actor.ActorRef	snapshotStore()

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

$init$, defer, deferAsync, persist, persistAll, persistAllAsync, persistAsync, receive

Methods inherited from interface akka.persistence.Eventsourced

$init$, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$extension_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$instanceId_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$internalStash_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$maxMessageBatchSize_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$pendingInvocations_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$persistingEvents_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$processingCommands_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$unstashFilterPredicate_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$writerUuid_$eq, akka$persistence$Eventsourced$$_lastSequenceNr_$eq, akka$persistence$Eventsourced$$_lastSequenceNr, akka$persistence$Eventsourced$$changeState, akka$persistence$Eventsourced$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$flushBatch, akka$persistence$Eventsourced$$flushJournalBatch, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$peekApplyHandler, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$recovering, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$setLastSequenceNr, akka$persistence$Eventsourced$$startRecovery, akka$persistence$Eventsourced$$stashInternally, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$unstashInternally, akka$persistence$Eventsourced$$updateLastSequenceNr, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, deleteMessages, internalDefer, internalDeferAsync, internalDeleteMessagesBeforeSnapshot, internalPersist, internalPersistAll, internalPersistAllAsync, internalPersistAsync, lastSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, recoveryFinished, recoveryRunning, snapshotSequenceNr, snapshotterId, stash, unhandled, unstashAll

Methods inherited from interface akka.persistence.Snapshotter

$init$, deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot

Methods inherited from interface akka.persistence.PersistenceStash

$init$, internalStashOverflowStrategy

Methods inherited from interface akka.actor.UnrestrictedStash

$init$

Methods inherited from interface akka.actor.Actor

$init$, noSender, postRestart, preStart, sender, supervisorStrategy

Methods inherited from interface akka.actor.StashSupport

$init$, akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, prepend, unstash, unstashAll

Methods inherited from interface akka.actor.StashFactory

$init$, createStash

Methods inherited from interface akka.persistence.PersistenceIdentity

$init$

Methods inherited from interface akka.persistence.PersistenceRecovery

$init$, recovery

Constructor Detail

AwaitPersistenceInit

public AwaitPersistenceInit(java.lang.String journalPluginId,
                            java.lang.String snapshotPluginId)

Method Detail

akka$actor$Actor$_setter_$context_$eq

protected void akka$actor$Actor$_setter_$context_$eq(akka.actor.ActorContext x$1)

Specified by:

akka$actor$Actor$_setter_$context_$eq in interface akka.actor.Actor

akka$actor$Actor$_setter_$self_$eq

protected final void akka$actor$Actor$_setter_$self_$eq(akka.actor.ActorRef x$1)

Specified by:

akka$actor$Actor$_setter_$self_$eq in interface akka.actor.Actor

akka$actor$StashSupport$_setter_$mailbox_$eq

protected void akka$actor$StashSupport$_setter_$mailbox_$eq(akka.dispatch.DequeBasedMessageQueueSemantics x$1)

Specified by:

akka$actor$StashSupport$_setter_$mailbox_$eq in interface akka.actor.StashSupport

context

public akka.actor.ActorContext context()

Specified by:

context in interface akka.actor.Actor

Specified by:

context in interface akka.actor.StashSupport

journal

protected akka.actor.ActorRef journal()

Specified by:

journal in interface akka.persistence.Eventsourced

journalPluginId

public java.lang.String journalPluginId()

Specified by:

journalPluginId in interface akka.persistence.PersistenceIdentity

mailbox

public akka.dispatch.DequeBasedMessageQueueSemantics mailbox()

Specified by:

mailbox in interface akka.actor.StashSupport

persistenceId

public java.lang.String persistenceId()

Specified by:

persistenceId in interface akka.persistence.PersistenceIdentity

receiveCommand

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

Specified by:

receiveCommand in interface akka.persistence.Eventsourced

receiveRecover

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

Specified by:

receiveRecover in interface akka.persistence.Eventsourced

self

public final akka.actor.ActorRef self()

Specified by:

self in interface akka.actor.Actor

Specified by:

self in interface akka.actor.StashSupport

snapshotPluginId

public java.lang.String snapshotPluginId()

Specified by:

snapshotPluginId in interface akka.persistence.PersistenceIdentity

snapshotStore

protected akka.actor.ActorRef snapshotStore()

Specified by:

snapshotStore in interface akka.persistence.Eventsourced

Specified by:

snapshotStore in interface akka.persistence.Snapshotter