Package org.apache.pekko.cluster.sharding

Class PersistentShardCoordinator

    • Method Detail

      • 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 in pekko.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

      • 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 interface PersistenceIdentity

      • 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 calling persist.
        Specified by:
        receiveCommand in interface Eventsourced

      • 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 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
        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 in pekko.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

      • update

        public <E extends org.apache.pekko.cluster.sharding.ShardCoordinator.Internal.DomainEvent> void update​(E evt,
                                                                                                       scala.Function1<E,​scala.runtime.BoxedUnit> f)
        Deprecated.
        Specified by:
        update in class ShardCoordinator

      • waitingForStateInitialized

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