Package akka.cluster.sharding
Class PersistentShardCoordinator
- java.lang.Object
-
- akka.cluster.sharding.ShardCoordinator
-
- akka.cluster.sharding.PersistentShardCoordinator
-
- All Implemented Interfaces:
Actor
,Stash
,StashFactory
,StashSupport
,Timers
,UnrestrictedStash
,RequiresMessageQueue<DequeBasedMessageQueueSemantics>
,Eventsourced
,PersistenceIdentity
,PersistenceRecovery
,PersistenceStash
,PersistentActor
,Snapshotter
public class PersistentShardCoordinator extends ShardCoordinator implements PersistentActor
Deprecated.Use `ddata` mode, persistence mode is deprecated. Since 2.6.0.Singleton coordinator that decides where to allocate shards.Users can migrate to using DData to store state then either Event Sourcing or ddata to store the remembered entities.
- See Also:
ClusterSharding extension
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.cluster.sharding.ShardCoordinator
ShardCoordinator.AbstractShardAllocationStrategy, ShardCoordinator.ActorSystemDependentAllocationStrategy, ShardCoordinator.Internal$, ShardCoordinator.LeastShardAllocationStrategy, ShardCoordinator.RebalanceWorker$, ShardCoordinator.ShardAllocationStrategy, ShardCoordinator.ShardAllocationStrategy$, ShardCoordinator.StartableAllocationStrategy
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
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
-
-
Constructor Summary
Constructors Constructor Description PersistentShardCoordinator(java.lang.String typeName, ClusterShardingSettings settings, ShardCoordinator.ShardAllocationStrategy allocationStrategy)
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description protected void
akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
Deprecated.protected ActorRef
journal()
Deprecated.java.lang.String
journalPluginId()
Deprecated.Configuration id of the journal plugin servicing this persistent actor.java.lang.String
persistenceId()
Deprecated.Id of the persistent entity for which messages should be replayed.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receiveCommand()
Deprecated.Command handler.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receiveRecover()
Deprecated.Recovery handler that receives persisted events during recovery.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receiveSnapshotResult()
Deprecated.void
saveSnapshotWhenNeeded()
Deprecated.java.lang.String
snapshotPluginId()
Deprecated.Configuration id of the snapshot plugin servicing this persistent actor.protected ActorRef
snapshotStore()
Deprecated.Snapshot store plugin actor.java.lang.String
typeName()
Deprecated.protected void
unstashOneGetShardHomeRequest()
Deprecated.<E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent>
voidupdate(E evt, scala.Function1<E,scala.runtime.BoxedUnit> f)
Deprecated.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
waitingForStateInitialized()
Deprecated.-
Methods inherited from class akka.cluster.sharding.ShardCoordinator
active, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aliveRegions, aliveRegions_$eq, allocateShardHomesForRememberEntities, allRegionsRegistered, allRegionsRegistered_$eq, cluster, context, continueGetShardHome, continueRebalance, gracefulShutdownInProgress, gracefulShutdownInProgress_$eq, handleGetShardHome, hasAllRegionsRegistered, isMember, leastShardAllocationStrategy, log, minMembers, postStop, preparingForShutdown, preparingForShutdown_$eq, preStart, rebalanceInProgress, rebalanceInProgress_$eq, rebalanceWorkers, rebalanceWorkers_$eq, receiveTerminated, regionProxyTerminated, regionTerminated, regionTerminationInProgress, regionTerminationInProgress_$eq, removalMargin, self, sendHostShardMsg, shutdownShards, shuttingDown, state, state_$eq, stateInitialized, unAckedHostShards, unAckedHostShards_$eq, waitingForLocalRegionToTerminate, waitingForLocalRegionToTerminate_$eq, waitingForShardsToStop, waitingForShardsToStop_$eq, watchStateActors
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface akka.actor.Actor
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, self, sender, supervisorStrategy
-
Methods inherited from interface akka.persistence.Eventsourced
_lastSequenceNr_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, batchAtomicWrite, changeState, currentCommand, currentState_$eq, deleteMessages, eventBatch_$eq, flushBatch, flushJournalBatch, getAndClearInstrumentationContext, instrumentationContexts_$eq, internalDefer, internalDeferAsync, internalDeleteMessagesBeforeSnapshot, internalPersist, internalPersistAll, internalPersistAllAsync, internalPersistAsync, journalBatch_$eq, lastSequenceNr, log, nextSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onRecoveryFailureAndInstrumentation, onReplaySuccess, peekApplyHandler, pendingStashingPersistInvocations_$eq, recovering, recoveryFinished, recoveryRunning, recoveryStarted, requestRecoveryPermit, sendBatchedEventsToJournal, sequenceNr_$eq, setLastSequenceNr, snapshotSequenceNr, snapshotterId, startRecovery, stash, stashInternally, super$aroundPostRestart, super$aroundPostStop, super$aroundPreRestart, super$aroundPreStart, super$aroundReceive, super$stash, super$unhandled, unhandled, unstashAll, unstashInternally, updateLastSequenceNr, waitingRecoveryPermit, writeEventFailed, writeEventRejected, writeEventSucceeded, writeInProgress_$eq
-
Methods inherited from interface akka.persistence.PersistenceRecovery
recovery
-
Methods inherited from interface akka.persistence.PersistenceStash
internalStashOverflowStrategy
-
Methods inherited from interface akka.persistence.PersistentActor
defer, deferAsync, persist, persistAll, persistAllAsync, persistAsync, receive
-
Methods inherited from interface akka.persistence.Snapshotter
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot
-
Methods inherited from interface akka.actor.StashFactory
createStash
-
Methods inherited from interface akka.actor.StashSupport
actorCell, clearStash, context, enqueueFirst, prepend, self, theStash_$eq, unstash, unstashAll
-
Methods inherited from interface akka.actor.Timers
actorCell, aroundPostStop, aroundPreRestart, aroundReceive, super$aroundPostStop, super$aroundPreRestart, super$aroundReceive, timers
-
Methods inherited from interface akka.actor.UnrestrictedStash
postStop, preRestart, super$postStop, super$preRestart
-
-
-
-
Constructor Detail
-
PersistentShardCoordinator
public PersistentShardCoordinator(java.lang.String typeName, ClusterShardingSettings settings, ShardCoordinator.ShardAllocationStrategy allocationStrategy)
Deprecated.
-
-
Method Detail
-
akka$actor$StashSupport$_setter_$mailbox_$eq
protected void akka$actor$StashSupport$_setter_$mailbox_$eq(DequeBasedMessageQueueSemantics x$1)
Deprecated.- Specified by:
akka$actor$StashSupport$_setter_$mailbox_$eq
in interfaceStashSupport
-
journal
protected ActorRef journal()
Deprecated.- Specified by:
journal
in interfaceEventsourced
-
journalPluginId
public java.lang.String journalPluginId()
Deprecated.Description copied from interface:PersistenceIdentity
Configuration id of the journal plugin servicing this persistent actor. When empty, looks inakka.persistence.journal.plugin
to find configuration entry path. When configured, usesjournalPluginId
as absolute path to the journal configuration entry. Configuration entry must contain few required fields, such asclass
. Seesrc/main/resources/reference.conf
.- Specified by:
journalPluginId
in interfacePersistenceIdentity
-
persistenceId
public java.lang.String persistenceId()
Deprecated.Description copied from interface:PersistenceIdentity
Id of the persistent entity for which messages should be replayed.- Specified by:
persistenceId
in interfacePersistenceIdentity
-
receiveCommand
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveCommand()
Deprecated.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 callingpersist
.- Specified by:
receiveCommand
in interfaceEventsourced
-
receiveRecover
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveRecover()
Deprecated.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 aSnapshotOffer
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 interfaceEventsourced
- See Also:
Recovery
-
receiveSnapshotResult
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveSnapshotResult()
Deprecated.
-
saveSnapshotWhenNeeded
public void saveSnapshotWhenNeeded()
Deprecated.
-
snapshotPluginId
public java.lang.String snapshotPluginId()
Deprecated.Description copied from interface:PersistenceIdentity
Configuration id of the snapshot plugin servicing this persistent actor. When empty, looks inakka.persistence.snapshot-store.plugin
to find configuration entry path. When configured, usessnapshotPluginId
as absolute path to the snapshot store configuration entry. Configuration entry must contain few required fields, such asclass
. Seesrc/main/resources/reference.conf
.- Specified by:
snapshotPluginId
in interfacePersistenceIdentity
-
snapshotStore
protected ActorRef snapshotStore()
Deprecated.Description copied from interface:Snapshotter
Snapshot store plugin actor.- Specified by:
snapshotStore
in interfaceEventsourced
- Specified by:
snapshotStore
in interfaceSnapshotter
-
typeName
public java.lang.String typeName()
Deprecated.- Specified by:
typeName
in classShardCoordinator
-
unstashOneGetShardHomeRequest
protected void unstashOneGetShardHomeRequest()
Deprecated.- Specified by:
unstashOneGetShardHomeRequest
in classShardCoordinator
-
update
public <E extends akka.cluster.sharding.ShardCoordinator.Internal.DomainEvent> void update(E evt, scala.Function1<E,scala.runtime.BoxedUnit> f)
Deprecated.- Specified by:
update
in classShardCoordinator
-
waitingForStateInitialized
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitingForStateInitialized()
Deprecated.
-
-