public class RemoveInternalClusterShardingData
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging
Modifier and Type | Class and Description |
---|---|
static class |
RemoveInternalClusterShardingData.RemoveOnePersistenceId
INTERNAL API: Remove all events and snapshots for one specific
persistenceId . |
static class |
RemoveInternalClusterShardingData.RemoveOnePersistenceId$
INTERNAL API
|
Constructor and Description |
---|
RemoveInternalClusterShardingData(java.lang.String journalPluginId,
scala.collection.immutable.Set<java.lang.String> typeNames,
scala.concurrent.Promise<scala.runtime.BoxedUnit> completion,
boolean remove2dot3Data) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
currentPid() |
akka.actor.ActorRef |
currentRef() |
void |
done() |
void |
failure(java.lang.Throwable cause) |
static void |
main(java.lang.String[] args) |
java.lang.String |
persistenceId(java.lang.String typeName) |
java.lang.String |
persistenceId2dot3(java.lang.String typeName) |
void |
preStart() |
static akka.actor.Props |
props(java.lang.String journalPluginId,
scala.collection.immutable.Set<java.lang.String> typeNames,
scala.concurrent.Promise<scala.runtime.BoxedUnit> completion,
boolean remove2dot3Data)
INTERNAL API:
Props for RemoveInternalClusterShardingData actor. |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
scala.collection.immutable.Set<java.lang.String> |
remainingPids() |
static scala.concurrent.Future<scala.runtime.BoxedUnit> |
remove(akka.actor.ActorSystem system,
java.lang.String journalPluginId,
scala.collection.immutable.Set<java.lang.String> typeNames,
boolean terminateSystem,
boolean remove2dot3Data)
API corresponding to the
main(java.lang.String[]) method as described in the
RemoveInternalClusterShardingData companion object |
void |
removeNext() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public RemoveInternalClusterShardingData(java.lang.String journalPluginId, scala.collection.immutable.Set<java.lang.String> typeNames, scala.concurrent.Promise<scala.runtime.BoxedUnit> completion, boolean remove2dot3Data)
public static void main(java.lang.String[] args)
args
- (undocumented)RemoveInternalClusterShardingData companion object
public static scala.concurrent.Future<scala.runtime.BoxedUnit> remove(akka.actor.ActorSystem system, java.lang.String journalPluginId, scala.collection.immutable.Set<java.lang.String> typeNames, boolean terminateSystem, boolean remove2dot3Data)
main(java.lang.String[])
method as described in the
RemoveInternalClusterShardingData companion object
system
- (undocumented)journalPluginId
- (undocumented)typeNames
- (undocumented)terminateSystem
- (undocumented)remove2dot3Data
- (undocumented)public static akka.actor.Props props(java.lang.String journalPluginId, scala.collection.immutable.Set<java.lang.String> typeNames, scala.concurrent.Promise<scala.runtime.BoxedUnit> completion, boolean remove2dot3Data)
Props
for RemoveInternalClusterShardingData
actor.journalPluginId
- (undocumented)typeNames
- (undocumented)completion
- (undocumented)remove2dot3Data
- (undocumented)public java.lang.String currentPid()
public akka.actor.ActorRef currentRef()
public scala.collection.immutable.Set<java.lang.String> remainingPids()
public java.lang.String persistenceId(java.lang.String typeName)
public java.lang.String persistenceId2dot3(java.lang.String typeName)
public void preStart()
preStart
in interface akka.actor.Actor
public void removeNext()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public void done()
public void failure(java.lang.Throwable cause)