Class RemoveInternalClusterShardingData.RemoveOnePersistenceId

    • Constructor Detail

      • RemoveOnePersistenceId

        public RemoveOnePersistenceId​(java.lang.String journalPluginId,
                                      java.lang.String persistenceId,
                                      ActorRef replyTo)
    • Method Detail

      • context

        public ActorContext context()
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        context in interface Actor
        Specified by:
        context in interface StashSupport
      • self

        public final ActorRef self()
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        self in interface Actor
        Specified by:
        self in interface StashSupport
      • akka$actor$Actor$_setter_$context_$eq

        protected void akka$actor$Actor$_setter_$context_$eq​(ActorContext x$1)
        Description copied from interface: Actor
        Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such as forward.

        WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!

        ActorContext is the Scala API. getContext returns a AbstractActor.ActorContext, which is the Java API of the actor context.

        Specified by:
        akka$actor$Actor$_setter_$context_$eq in interface Actor
      • akka$actor$Actor$_setter_$self_$eq

        protected final void akka$actor$Actor$_setter_$self_$eq​(ActorRef x$1)
        Description copied from interface: Actor
        The 'self' field holds the ActorRef for this actor.

        Can be used to send messages to itself:
         self ! message
         
        Specified by:
        akka$actor$Actor$_setter_$self_$eq in interface Actor
      • journalPluginId

        public java.lang.String journalPluginId()
        Description copied from interface: PersistenceIdentity
        Configuration id of the journal plugin servicing this persistent actor. 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
      • hasSnapshots

        public boolean hasSnapshots()
      • hasSnapshots_$eq

        public void hasSnapshots_$eq​(boolean x$1)
      • 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
        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
      • waitDeleteSnapshotsSuccess

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> waitDeleteSnapshotsSuccess()
      • waitDeleteMessagesSuccess

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> waitDeleteMessagesSuccess()
      • handleFailure

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> handleFailure()
      • done

        public void done()
      • failure

        public void failure​(java.lang.Throwable cause)