public static class RemoveInternalClusterShardingData.RemoveOnePersistenceId extends java.lang.Object implements PersistentActor
persistenceId
. It will reply with RemoveOnePersistenceId.Result
when done.Eventsourced.AsyncHandlerInvocation, Eventsourced.AsyncHandlerInvocation$, Eventsourced.PendingHandlerInvocation, Eventsourced.RecoveryTick, Eventsourced.RecoveryTick$, Eventsourced.StashingHandlerInvocation, Eventsourced.StashingHandlerInvocation$, Eventsourced.State
Actor.emptyBehavior$, Actor.ignoringBehavior$
Constructor and Description |
---|
RemoveOnePersistenceId(java.lang.String journalPluginId,
java.lang.String persistenceId,
ActorRef replyTo) |
Modifier and Type | Method and Description |
---|---|
ActorContext |
context()
Stores the context for this actor, including self, and sender.
|
void |
done() |
void |
failure(java.lang.Throwable cause) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
handleFailure() |
boolean |
hasSnapshots() |
protected ActorRef |
journal() |
java.lang.String |
journalPluginId()
Configuration id of the journal plugin servicing this persistent actor or view.
|
DequeBasedMessageQueueSemantics |
mailbox() |
java.lang.String |
persistenceId()
Id of the persistent entity for which messages should be replayed.
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveCommand()
Command handler.
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receiveRecover()
Recovery handler that receives persisted events during recovery.
|
ActorRef |
self()
The 'self' field holds the ActorRef for this actor.
|
protected ActorRef |
snapshotStore()
Snapshot store plugin actor.
|
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
receive
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, changeState, deferAsync, deleteMessages, flushBatch, flushJournalBatch, lastSequenceNr, log, nextSequenceNr, onPersistFailure, onPersistRejected, onRecoveryFailure, onReplaySuccess, peekApplyHandler, persist, persist, persistAll, persistAllAsync, persistAsync, persistAsync, recovering, recoveryFinished, recoveryRunning, recoveryStarted, requestRecoveryPermit, setLastSequenceNr, snapshotSequenceNr, snapshotterId, startRecovery, stashInternally, unhandled, unstashAll, unstashInternally, updateLastSequenceNr, waitingRecoveryPermit
deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot
internalStashOverflowStrategy
postRestart, preStart, sender, supervisorStrategy
actorCell, clearStash, enqueueFirst, prepend, stash, unstash, unstashAll
createStash
snapshotPluginId
recovery
public RemoveOnePersistenceId(java.lang.String journalPluginId, java.lang.String persistenceId, ActorRef replyTo)
protected ActorRef journal()
journal
in interface Eventsourced
protected ActorRef snapshotStore()
Snapshotter
snapshotStore
in interface Eventsourced
snapshotStore
in interface Snapshotter
public DequeBasedMessageQueueSemantics mailbox()
mailbox
in interface StashSupport
public ActorContext context()
Actor
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
UntypedActorContext
, which is the Java API of the actor
context.
context
in interface Actor
context
in interface StashSupport
public final ActorRef self()
Actor
self ! message
self
in interface Actor
self
in interface StashSupport
public java.lang.String journalPluginId()
PersistenceIdentity
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
.journalPluginId
in interface PersistenceIdentity
public java.lang.String persistenceId()
PersistenceIdentity
persistenceId
in interface PersistenceIdentity
public boolean hasSnapshots()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveRecover()
Eventsourced
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.
receiveRecover
in interface Eventsourced
Recovery
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receiveCommand()
Eventsourced
persist
.receiveCommand
in interface 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)