Class RemoveInternalClusterShardingData

    • Constructor Detail

      • RemoveInternalClusterShardingData

        public RemoveInternalClusterShardingData​(java.lang.String journalPluginId,
                                                 scala.collection.immutable.Set<java.lang.String> typeNames,
                                                 scala.concurrent.Promise<scala.runtime.BoxedUnit> completion,
                                                 boolean remove2dot3Data)
    • 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!

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

        Specified by:
        context in interface Actor
      • 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
      • org$apache$pekko$actor$Actor$_setter_$context_$eq

        protected void org$apache$pekko$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!

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

        Specified by:
        org$apache$pekko$actor$Actor$_setter_$context_$eq in interface Actor
      • org$apache$pekko$actor$Actor$_setter_$self_$eq

        protected final void org$apache$pekko$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:
        org$apache$pekko$actor$Actor$_setter_$self_$eq in interface Actor
      • currentPid

        public java.lang.String currentPid()
      • currentPid_$eq

        public void currentPid_$eq​(java.lang.String x$1)
      • currentRef

        public ActorRef currentRef()
      • currentRef_$eq

        public void currentRef_$eq​(ActorRef x$1)
      • remainingPids

        public scala.collection.immutable.Set<java.lang.String> remainingPids()
      • remainingPids_$eq

        public void remainingPids_$eq​(scala.collection.immutable.Set<java.lang.String> x$1)
      • persistenceId

        public java.lang.String persistenceId​(java.lang.String typeName)
      • persistenceId2dot3

        public java.lang.String persistenceId2dot3​(java.lang.String typeName)
      • preStart

        public void preStart()
        Description copied from interface: Actor
        User overridable callback.

        Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.
        Specified by:
        preStart in interface Actor
      • removeNext

        public void removeNext()
      • receive

        public scala.PartialFunction<java.lang.Object,​scala.runtime.BoxedUnit> receive()
        Description copied from interface: Actor
        Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
        Specified by:
        receive in interface Actor
      • done

        public void done()
      • failure

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