akka.persistence.multidc.internal

Class ReplicatedEntityActor<C,E,S>

java.lang.Object

akka.persistence.multidc.internal.ReplicatedEntityActor<C,E,S>

All Implemented Interfaces:

akka.actor.Actor, akka.actor.Stash, akka.actor.StashFactory, akka.actor.StashSupport, akka.actor.Timers, 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

public class ReplicatedEntityActor<C,E,S>
extends java.lang.Object
implements akka.actor.Timers, akka.persistence.PersistentActor

INTERNAL API The PersistentActor that runs a ReplicatedEntity.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ReplicatedEntityActor.Protocol
static class	ReplicatedEntityActor.ReplicatedEventAck$
static class	ReplicatedEntityActor.ReplicatedEventMetaData
static class	ReplicatedEntityActor.ReplicatedEventMetaData$
static class	ReplicatedEntityActor.SpeculativeReplicatedEventImpl<Event>
static class	ReplicatedEntityActor.SpeculativeReplicatedEventImpl$
static class	ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl Used when sending back to the originDc.
static class	ReplicatedEntityActor.SpeculativeReplicatedEventLightImpl$

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
ReplicatedEntityActor(java.lang.Class<C> commandClass, java.lang.String persistenceIdPrefix, scala.Option<java.lang.String> id, InternalReplicatedEntity<C,E,S> entity, PersistenceMultiDcSettings settings)

Method Summary

Modifier and Type	Method and Description
void	applyEventTrigger(S s, ReplicatedEvent<E> re)
S	applyReplicatedEvent(S s, ReplicatedEvent<E> re) Apply an event that was replicated from another DC to the given state.
S	applySelfEvent(S s, ReplicatedEvent<E> re) Apply an event that was persisted by this data center to the given state.
protected void	aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg) INTERNAL API
<EE> ReplicatedEvent<EE>	createReplicatedEvent(EE event, long sequenceNr)
static char	EntityIdSeparator()
java.lang.String	journalPluginId()
void	onSnapshotReceived(ReplicatedEntitySnapshot<S> snapshot)
<A> void	persist(A event, scala.Function1<A,scala.runtime.BoxedUnit> handler)
<A> void	persistAll(scala.collection.immutable.Seq<A> events, scala.Function1<A,scala.runtime.BoxedUnit> handler)
<A> void	persistAllAsync(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)
java.lang.String	persistenceId()
void	postStop()
static <C,E,S> akka.actor.Props	props(java.lang.Class<C> commandClass, java.lang.String persistenceIdPrefix, scala.Option<java.lang.String> entityId, scala.Function0<InternalReplicatedEntity<C,E,S>> entityFactory, PersistenceMultiDcSettings settings)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveCommand()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveRecover()
void	saveSnapshotWithReplicationState()
akka.actor.SupervisorStrategy	supervisorStrategy()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.Timers

akka$actor$Timers$_setter_$akka$actor$Timers$$_timers_$eq, akka$actor$Timers$$_timers, aroundPostStop, aroundPreRestart, timers

Methods inherited from interface akka.persistence.PersistentActor

defer, deferAsync, receive

Methods inherited from interface akka.persistence.Eventsourced

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$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPreStart, deleteMessages, internalDefer, internalDeferAsync, internalDeleteMessagesBeforeSnapshot, internalPersist, internalPersistAll, internalPersistAllAsync, internalPersistAsync, journal, lastSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, recoveryFinished, recoveryRunning, snapshotSequenceNr, snapshotStore, snapshotterId, stash, unhandled, unstashAll

Methods inherited from interface akka.persistence.Snapshotter

deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot

Methods inherited from interface akka.persistence.PersistenceStash

internalStashOverflowStrategy

Methods inherited from interface akka.actor.Actor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, self, sender

Methods inherited from interface akka.actor.StashSupport

akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, unstash, unstashAll

Methods inherited from interface akka.actor.StashFactory

createStash

Methods inherited from interface akka.persistence.PersistenceIdentity

snapshotPluginId

Methods inherited from interface akka.persistence.PersistenceRecovery

recovery

Constructor Detail

ReplicatedEntityActor

public ReplicatedEntityActor(java.lang.Class<C> commandClass,
                             java.lang.String persistenceIdPrefix,
                             scala.Option<java.lang.String> id,
                             InternalReplicatedEntity<C,E,S> entity,
                             PersistenceMultiDcSettings settings)

Method Detail

EntityIdSeparator

public static char EntityIdSeparator()

props

public static <C,E,S> akka.actor.Props props(java.lang.Class<C> commandClass,
                                             java.lang.String persistenceIdPrefix,
                                             scala.Option<java.lang.String> entityId,
                                             scala.Function0<InternalReplicatedEntity<C,E,S>> entityFactory,
                                             PersistenceMultiDcSettings settings)

persistenceId

public java.lang.String persistenceId()

Specified by:

persistenceId in interface akka.persistence.PersistenceIdentity

journalPluginId

public java.lang.String journalPluginId()

Specified by:

journalPluginId in interface akka.persistence.PersistenceIdentity

supervisorStrategy

public akka.actor.SupervisorStrategy supervisorStrategy()

Specified by:

supervisorStrategy in interface akka.actor.Actor

postStop

public void postStop()

Specified by:

postStop in interface akka.actor.Actor

Specified by:

postStop in interface akka.actor.UnrestrictedStash

aroundReceive

protected void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
                             java.lang.Object msg)

INTERNAL API

Specified by:

aroundReceive in interface akka.actor.Actor

Specified by:

aroundReceive in interface akka.actor.Timers

Specified by:

aroundReceive in interface akka.persistence.Eventsourced

receiveRecover

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

Specified by:

receiveRecover in interface akka.persistence.Eventsourced

createReplicatedEvent

public <EE> ReplicatedEvent<EE> createReplicatedEvent(EE event,
                                                      long sequenceNr)

applyReplicatedEvent

public S applyReplicatedEvent(S s,
                              ReplicatedEvent<E> re)

Apply an event that was replicated from another DC to the given state.

Parameters:

s - (undocumented)

re - (undocumented)

Returns:

(undocumented)

applySelfEvent

public S applySelfEvent(S s,
                        ReplicatedEvent<E> re)

Apply an event that was persisted by this data center to the given state.

Parameters:

s - (undocumented)

re - (undocumented)

Returns:

(undocumented)

applyEventTrigger

public void applyEventTrigger(S s,
                              ReplicatedEvent<E> re)

receiveCommand

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

Specified by:

receiveCommand in interface akka.persistence.Eventsourced

persist

public <A> void persist(A event,
                        scala.Function1<A,scala.runtime.BoxedUnit> handler)

Specified by:

persist in interface akka.persistence.PersistentActor

persistAll

public <A> void persistAll(scala.collection.immutable.Seq<A> events,
                           scala.Function1<A,scala.runtime.BoxedUnit> handler)

Specified by:

persistAll in interface akka.persistence.PersistentActor

persistAsync

public <A> void persistAsync(A event,
                             scala.Function1<A,scala.runtime.BoxedUnit> handler)

Specified by:

persistAsync in interface akka.persistence.PersistentActor

persistAllAsync

public <A> void persistAllAsync(scala.collection.immutable.Seq<A> events,
                                scala.Function1<A,scala.runtime.BoxedUnit> handler)

Specified by:

persistAllAsync in interface akka.persistence.PersistentActor

saveSnapshotWithReplicationState

public void saveSnapshotWithReplicationState()

onSnapshotReceived

public void onSnapshotReceived(ReplicatedEntitySnapshot<S> snapshot)