public static class RemoveInternalClusterShardingData.RemoveOnePersistenceId
extends java.lang.Object
implements akka.persistence.PersistentActor
persistenceId
. It will reply with RemoveOnePersistenceId.Result
when done.Modifier and Type | Class and Description |
---|---|
static class |
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals |
static class |
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Removals$ |
static class |
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result |
static class |
RemoveInternalClusterShardingData.RemoveOnePersistenceId.Result$ |
akka.persistence.Eventsourced.AsyncHandlerInvocation, akka.persistence.Eventsourced.AsyncHandlerInvocation$, akka.persistence.Eventsourced.PendingHandlerInvocation, akka.persistence.Eventsourced.ProcessingState, akka.persistence.Eventsourced.StashingHandlerInvocation, akka.persistence.Eventsourced.StashingHandlerInvocation$, akka.persistence.Eventsourced.State
Constructor and Description |
---|
RemoveOnePersistenceId(java.lang.String journalPluginId,
java.lang.String persistenceId,
akka.actor.ActorRef replyTo) |
Modifier and Type | Method and Description |
---|---|
void |
done() |
void |
failure(java.lang.Throwable cause) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
handleFailure() |
boolean |
hasSnapshots() |
java.lang.String |
journalPluginId() |
java.lang.String |
persistenceId() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveCommand() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveRecover() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
waitDeleteMessagesSuccess() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
waitDeleteSnapshotsSuccess() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$extension_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$instanceId_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$internalStash_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$maxMessageBatchSize_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$pendingInvocations_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$persistingEvents_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$processingCommands_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$unstashFilterPredicate_$eq, akka$persistence$Eventsourced$_setter_$akka$persistence$Eventsourced$$writerUuid_$eq, akka$persistence$Eventsourced$$_lastSequenceNr_$eq, akka$persistence$Eventsourced$$_lastSequenceNr, akka$persistence$Eventsourced$$currentState_$eq, akka$persistence$Eventsourced$$currentState, akka$persistence$Eventsourced$$eventBatch_$eq, akka$persistence$Eventsourced$$eventBatch, akka$persistence$Eventsourced$$extension, akka$persistence$Eventsourced$$instanceId, akka$persistence$Eventsourced$$internalStash, akka$persistence$Eventsourced$$journalBatch_$eq, akka$persistence$Eventsourced$$journalBatch, akka$persistence$Eventsourced$$maxMessageBatchSize, akka$persistence$Eventsourced$$pendingInvocations, akka$persistence$Eventsourced$$pendingStashingPersistInvocations_$eq, akka$persistence$Eventsourced$$pendingStashingPersistInvocations, akka$persistence$Eventsourced$$persistingEvents, akka$persistence$Eventsourced$$processingCommands, akka$persistence$Eventsourced$$sequenceNr_$eq, akka$persistence$Eventsourced$$sequenceNr, akka$persistence$Eventsourced$$unstashFilterPredicate, akka$persistence$Eventsourced$$writeInProgress_$eq, akka$persistence$Eventsourced$$writeInProgress, akka$persistence$Eventsourced$$writerUuid, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, deferAsync, deleteMessages, journal, lastSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, persist, persist, persistAll, persistAllAsync, persistAsync, persistAsync, recoveryFinished, recoveryRunning, snapshotSequenceNr, snapshotStore, snapshotterId, unhandled, unstashAll
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot
akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, context, postRestart, preStart, self, sender, supervisorStrategy
akka$actor$StashSupport$_setter_$akka$actor$StashSupport$$capacity_$eq, akka$actor$StashSupport$_setter_$mailbox_$eq, akka$actor$StashSupport$$capacity, akka$actor$StashSupport$$theStash_$eq, akka$actor$StashSupport$$theStash, clearStash, context, mailbox, prepend, self, stash, unstash, unstashAll
public RemoveOnePersistenceId(java.lang.String journalPluginId, java.lang.String persistenceId, akka.actor.ActorRef replyTo)
public java.lang.String journalPluginId()
journalPluginId
in interface akka.persistence.PersistenceIdentity
public java.lang.String persistenceId()
persistenceId
in interface akka.persistence.PersistenceIdentity
public boolean hasSnapshots()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveRecover()
receiveRecover
in interface akka.persistence.Eventsourced
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveCommand()
receiveCommand
in interface akka.persistence.Eventsourced
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitDeleteSnapshotsSuccess()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> waitDeleteMessagesSuccess()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> handleFailure()
public void done()
public void failure(java.lang.Throwable cause)