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.

Nested Class Summary

static class

RequestWriter.RequestsWritten$

Nested classes/interfaces inherited from interface akka.persistence.Recovery

Recovery.State

Nested classes/interfaces inherited from interface akka.actor.Actor

Actor.emptyBehavior$

Constructor Summary

RequestWriter(java.lang.String channelId, PersistentChannelSettings channelSettings, ActorRef reader)

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.persistence.Snapshotter

deleteSnapshot, deleteSnapshots, loadSnapshot, saveSnapshot, snapshotStore

Methods inherited from interface akka.actor.UnrestrictedStash

postStop

Methods inherited from interface akka.actor.Actor

aroundPostRestart, context, postRestart, self, sender, supervisorStrategy

Methods inherited from interface akka.actor.StashSupport

actorCell, capacity, clearStash, context, enqueueFirst, mailbox, prepend, self, stash, theStash, unstash, unstashAll, unstashAll

Methods inherited from interface akka.actor.StashFactory

createStash

Constructor Detail

RequestWriter

public RequestWriter(java.lang.String channelId,
                     PersistentChannelSettings channelSettings,
                     ActorRef reader)

Method Detail

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