akka.cluster.sharding

Class PersistentShardCoordinator

java.lang.Object

akka.cluster.sharding.ShardCoordinator

akka.cluster.sharding.PersistentShardCoordinator

All Implemented Interfaces:

Actor, ActorLogging, Stash, StashFactory, StashSupport, UnrestrictedStash, RequiresMessageQueue<DequeBasedMessageQueueSemantics>, Eventsourced, PersistenceIdentity, PersistenceRecovery, PersistenceStash, PersistentActor, Snapshotter

public class PersistentShardCoordinator
extends ShardCoordinator
implements PersistentActor

Singleton coordinator that decides where to allocate shards.

See Also:

ClusterSharding extension

Nested Class Summary

Nested classes/interfaces inherited from class akka.cluster.sharding.ShardCoordinator

ShardCoordinator.AbstractShardAllocationStrategy, ShardCoordinator.Internal$, ShardCoordinator.LeastShardAllocationStrategy, ShardCoordinator.RebalanceWorker, ShardCoordinator.ShardAllocationStrategy

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

Eventsourced.AsyncHandlerInvocation, Eventsourced.AsyncHandlerInvocation$, Eventsourced.PendingHandlerInvocation, Eventsourced.RecoveryTick, Eventsourced.RecoveryTick$, Eventsourced.StashingHandlerInvocation, Eventsourced.StashingHandlerInvocation$, Eventsourced.State

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor and Description
PersistentShardCoordinator(java.lang.String typeName, ClusterShardingSettings settings, ShardCoordinator.ShardAllocationStrategy allocationStrategy)

Method Summary

Modifier and Type	Method and Description
protected ActorRef	journal()
java.lang.String	journalPluginId() Configuration id of the journal plugin servicing this persistent actor or view.
DequeBasedMessageQueueSemantics	mailbox()
java.lang.String	persistenceId() Id of the persistent entity for which messages should be replayed.
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveCommand() Command handler.
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveRecover() Recovery handler that receives persisted events during recovery.
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receiveSnapshotResult()
void	saveSnapshotWhenNeeded()
java.lang.String	snapshotPluginId() Configuration id of the snapshot plugin servicing this persistent actor or view.
protected ActorRef	snapshotStore() Snapshot store plugin actor.
<E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> void	update(E evt, scala.Function1<E,scala.runtime.BoxedUnit> f)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	waitingForStateInitialized()

Methods inherited from class akka.cluster.sharding.ShardCoordinator

active, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, aliveRegions, allocateShardHomesForRememberEntities, allRegionsRegistered, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, cluster, context, continueGetShardHome, continueRebalance, gracefulShutdownInProgress, hasAllRegionsRegistered, isMember, log, minMembers, postRestart, postStop, preRestart, preStart, props, props, rebalanceInProgress, rebalanceTask, rebalanceWorkerProps, receive, receiveTerminated, regionProxyTerminated, regionTerminated, regionTerminationInProgress, removalMargin, self, sender, sendHostShardMsg, shuttingDown, state, stateInitialized, supervisorStrategy, unAckedHostShards, unhandled, watchStateActors

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

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, changeState, deferAsync, deleteMessages, flushBatch, flushJournalBatch, lastSequenceNr, log, nextSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, peekApplyHandler, persist, persist, persistAll, persistAllAsync, persistAsync, persistAsync, recovering, recoveryFinished, recoveryRunning, recoveryStarted, requestRecoveryPermit, setLastSequenceNr, snapshotSequenceNr, snapshotterId, startRecovery, stashInternally, unhandled, unstashAll, unstashInternally, updateLastSequenceNr, waitingRecoveryPermit

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

context, postRestart, preStart, self, sender, supervisorStrategy

Methods inherited from interface akka.actor.StashSupport

actorCell, clearStash, context, enqueueFirst, prepend, self, stash, unstash, unstashAll

Methods inherited from interface akka.actor.StashFactory

createStash

Methods inherited from interface akka.persistence.PersistenceRecovery

recovery

Methods inherited from interface akka.actor.ActorLogging

log

Constructor Detail

PersistentShardCoordinator

public PersistentShardCoordinator(java.lang.String typeName,
                                  ClusterShardingSettings settings,
                                  ShardCoordinator.ShardAllocationStrategy allocationStrategy)

Method Detail

journal

protected ActorRef journal()

Specified by:

journal in interface Eventsourced

snapshotStore

protected ActorRef snapshotStore()

Description copied from interface: Snapshotter

Snapshot store plugin actor.

Specified by:

snapshotStore in interface Eventsourced

Specified by:

snapshotStore in interface Snapshotter

mailbox

public DequeBasedMessageQueueSemantics mailbox()

Specified by:

mailbox in interface StashSupport

persistenceId

public java.lang.String persistenceId()

Description copied from interface: PersistenceIdentity

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

Specified by:

persistenceId in interface PersistenceIdentity

Returns:

(undocumented)

journalPluginId

public java.lang.String journalPluginId()

Description copied from interface: PersistenceIdentity

Configuration id of the journal plugin servicing this persistent actor or view. When empty, looks in akka.persistence.journal.plugin to find configuration entry path. When configured, uses journalPluginId as absolute path to the journal configuration entry. Configuration entry must contain few required fields, such as class. See src/main/resources/reference.conf.

Specified by:

journalPluginId in interface PersistenceIdentity

Returns:

(undocumented)

snapshotPluginId

public java.lang.String snapshotPluginId()

Description copied from interface: PersistenceIdentity

Configuration id of the snapshot plugin servicing this persistent actor or view. When empty, looks in akka.persistence.snapshot-store.plugin to find configuration entry path. When configured, uses snapshotPluginId as absolute path to the snapshot store configuration entry. Configuration entry must contain few required fields, such as class. See src/main/resources/reference.conf.

Specified by:

snapshotPluginId in interface PersistenceIdentity

Returns:

(undocumented)

receiveRecover

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

Description copied from interface: Eventsourced

Recovery handler that receives persisted events during recovery. If a state snapshot has been captured and saved, this handler will receive a SnapshotOffer message followed by events that are younger than the offered snapshot.

This handler must not have side-effects other than changing persistent actor state i.e. it should not perform actions that may fail, such as interacting with external services, for example.

If there is a problem with recovering the state of the actor from the journal, the error will be logged and the actor will be stopped.

Specified by:

receiveRecover in interface Eventsourced

Returns:

(undocumented)

See Also:

Recovery

receiveCommand

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

Description copied from interface: Eventsourced

Command handler. Typically validates commands against current state (and/or by communication with other actors). On successful validation, one or more events are derived from a command and these events are then persisted by calling persist.

Specified by:

receiveCommand in interface Eventsourced

Returns:

(undocumented)

waitingForStateInitialized

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

receiveSnapshotResult

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

update

public <E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> void update(E evt,
                                                                                           scala.Function1<E,scala.runtime.BoxedUnit> f)

Specified by:

update in class ShardCoordinator

saveSnapshotWhenNeeded

public void saveSnapshotWhenNeeded()