akka.persistence
Class RequestWriter
java.lang.Object
akka.persistence.RequestWriter
- All Implemented Interfaces:
- Actor, Stash, StashFactory, StashSupport, UnrestrictedStash, RequiresMessageQueue<DequeBasedMessageQueueSemantics>, Processor, ProcessorImpl, Recovery, Snapshotter
public class RequestWriter
- extends java.lang.Object
- implements Processor
Writes Deliver
requests to the journal.
Method Summary |
protected void |
aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object message)
INTERNAL API. |
java.lang.String |
persistenceId()
Persistence id. |
void |
preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
User-overridable callback. |
void |
preStart()
User-overridable callback. |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive()
This defines the initial actor behavior, it must return a partial function
with the actor logic. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.persistence.ProcessorImpl |
_persistenceId, aroundPostStop, aroundPreRestart, aroundPreStart, deleteMessage, deleteMessage, deleteMessages, deleteMessages, flushJournalBatch, initializing, instanceId, nextSequenceNr, onRecoveryCompleted, onRecoveryFailure, onReplayFailure, onReplaySuccess, preRestartDefault, processing, processorBatch, processorId, recoveryFinished, recoveryRunning, sequenceNr, snapshotterId, unhandled, unstashFilterPredicate |
Methods inherited from interface akka.persistence.Recovery |
_currentPersistent, _currentState, _lastSequenceNr, _recoveryFailureCause, _recoveryFailureMessage, currentPersistentMessage, extension, getCurrentPersistentMessage, journal, lastSequenceNr, prepareRestart, receiverStash, recoveryPending, recoveryStarted, replayFailed, replayStarted, runReceive, snapshotSequenceNr, updateLastSequenceNr, updateLastSequenceNr, withCurrentPersistent |
Methods inherited from interface akka.actor.StashSupport |
actorCell, capacity, clearStash, context, enqueueFirst, mailbox, prepend, self, stash, theStash, unstash, unstashAll, unstashAll |
RequestWriter
public RequestWriter(java.lang.String channelId,
PersistentChannelSettings channelSettings,
ActorRef reader)
persistenceId
public java.lang.String persistenceId()
- Description copied from interface:
Processor
- Persistence id. Defaults to this persistent-actors's path and can be overridden.
- Specified by:
persistenceId
in interface Processor
- Specified by:
persistenceId
in interface Recovery
- Returns:
- (undocumented)
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor
- Returns:
- (undocumented)
aroundReceive
protected void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
java.lang.Object message)
- Description copied from interface:
Actor
- INTERNAL API.
Can be overridden to intercept calls to this actor's current behavior.
- Specified by:
aroundReceive
in interface Actor
- Specified by:
aroundReceive
in interface Recovery
- Parameters:
receive
- current behavior.message
- current message.
preRestart
public void preRestart(java.lang.Throwable reason,
scala.Option<java.lang.Object> message)
- Description copied from interface:
ProcessorImpl
- User-overridable callback. Called before a processor is restarted. Default implementation sends
a
Recover(lastSequenceNr)
message to self
if message
is defined, Recover() otherwise
.
- Specified by:
preRestart
in interface Actor
- Specified by:
preRestart
in interface UnrestrictedStash
- Specified by:
preRestart
in interface ProcessorImpl
- Parameters:
reason
- (undocumented)message
- (undocumented)
preStart
public void preStart()
- Description copied from interface:
ProcessorImpl
- User-overridable callback. Called when a processor is started. Default implementation sends
a
Recover()
to self
.
- Specified by:
preStart
in interface Actor
- Specified by:
preStart
in interface ProcessorImpl