Class RemoveInternalClusterShardingData
- java.lang.Object
-
- org.apache.pekko.cluster.sharding.RemoveInternalClusterShardingData
-
- All Implemented Interfaces:
Actor
,ActorLogging
public class RemoveInternalClusterShardingData extends java.lang.Object implements Actor, ActorLogging
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
RemoveInternalClusterShardingData.RemoveOnePersistenceId$
INTERNAL API-
Nested classes/interfaces inherited from interface org.apache.pekko.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description RemoveInternalClusterShardingData(java.lang.String journalPluginId, scala.collection.immutable.Set<java.lang.String> typeNames, scala.concurrent.Promise<scala.runtime.BoxedUnit> completion, boolean remove2dot3Data)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.java.lang.String
currentPid()
void
currentPid_$eq(java.lang.String x$1)
ActorRef
currentRef()
void
currentRef_$eq(ActorRef x$1)
void
done()
void
failure(java.lang.Throwable cause)
static void
main(java.lang.String[] args)
protected void
org$apache$pekko$actor$Actor$_setter_$context_$eq(ActorContext x$1)
Scala API: Stores the context for this actor, including self, and sender.protected void
org$apache$pekko$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.java.lang.String
persistenceId(java.lang.String typeName)
java.lang.String
persistenceId2dot3(java.lang.String typeName)
void
preStart()
User overridable callback.scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.scala.collection.immutable.Set<java.lang.String>
remainingPids()
void
remainingPids_$eq(scala.collection.immutable.Set<java.lang.String> x$1)
static scala.concurrent.Future<scala.runtime.BoxedUnit>
remove(ActorSystem system, java.lang.String journalPluginId, scala.collection.immutable.Set<java.lang.String> typeNames, boolean remove2dot3Data)
API corresponding to themain(java.lang.String[])
method as described in theRemoveInternalClusterShardingData companion object
void
removeNext()
ActorRef
self()
The 'self' field holds the ActorRef for this actor.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.pekko.actor.Actor
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, postStop, preRestart, sender, supervisorStrategy, unhandled
-
Methods inherited from interface org.apache.pekko.actor.ActorLogging
_log_$eq, log
-
-
-
-
Method Detail
-
main
public static void main(java.lang.String[] args)
-
remove
public static scala.concurrent.Future<scala.runtime.BoxedUnit> remove(ActorSystem system, java.lang.String journalPluginId, scala.collection.immutable.Set<java.lang.String> typeNames, boolean remove2dot3Data)
API corresponding to themain(java.lang.String[])
method as described in theRemoveInternalClusterShardingData companion object
-
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 asforward
.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 apekko.actor.AbstractActor.ActorContext
, which is the Java API of the actor context.
-
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
-
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 asforward
.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 apekko.actor.AbstractActor.ActorContext
, which is the Java API of the actor context.- Specified by:
org$apache$pekko$actor$Actor$_setter_$context_$eq
in interfaceActor
-
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 interfaceActor
-
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.
-
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.
-
done
public void done()
-
failure
public void failure(java.lang.Throwable cause)
-
-