akka.remote
Class EndpointWriter

java.lang.Object
  akka.remote.EndpointActor
      akka.remote.EndpointWriter

All Implemented Interfaces:

Actor, ActorLogging

public class EndpointWriter
extends EndpointActor

INTERNAL API

Nested Class Summary

static class	EndpointWriter.AckIdleCheckTimer$
static class	EndpointWriter.BackoffTimer$
static class	EndpointWriter.FlushAndStop$
static class	EndpointWriter.Handle
static class	EndpointWriter.Handle$
static class	EndpointWriter.OutboundAck
static class	EndpointWriter.OutboundAck$
static class	EndpointWriter.StoppedReading
static class	EndpointWriter.StoppedReading$
static class	EndpointWriter.StopReading
static class	EndpointWriter.StopReading$
static class	EndpointWriter.TakeOver This message signals that the current association maintained by the local EndpointWriter and EndpointReader is to be overridden by a new inbound association.
static class	EndpointWriter.TakeOver$
static class	EndpointWriter.TookOver
static class	EndpointWriter.TookOver$

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

Actor.emptyBehavior$

Constructor Summary

EndpointWriter(scala.Option<AkkaProtocolHandle> handleOrActive, Address localAddress, Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers, scala.Option<ActorRef> reliableDeliverySupervisor)

Method Summary

scala.concurrent.duration.Deadline	ackDeadline()
Cancellable	ackIdleTimer()
long	adaptiveBackoffNanos()
void	adjustAdaptiveBackup()
MessageDispatcher	backoffDispatcher()
void	becomeWritingOrSendBufferedMessages()
java.util.LinkedList<java.lang.Object>	buffer()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	buffering()
void	enqueueInBuffer(java.lang.Object msg)
ExtendedActorSystem	extendedSystem()
void	flushAndStop()
boolean	fullBackoff()
int	fullBackoffCount()
scala.Option<AkkaProtocolHandle>	handle()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	handoff()
boolean	inbound()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	initializing()
long	largeBufferLogTimestamp()
scala.Option<Ack>	lastAck()
int	maxWriteCount()
DefaultMessageDispatcher	msgDispatch()
scala.concurrent.duration.Deadline	newAckDeadline()
int	noBackoffCount()
void	postRestart(java.lang.Throwable reason) User overridable callback: By default it calls preStart().
void	postStop() User overridable callback.
void	preStart() User overridable callback.
java.util.LinkedList<EndpointManager.Send>	prioBuffer()
static Props	props(scala.Option<AkkaProtocolHandle> handleOrActive, Address localAddress, Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers, scala.Option<ActorRef> reliableDeliverySupervisor)
RemoteActorRefProvider	provider()
scala.Option<ActorRef>	reader()
scala.collection.Iterator<java.lang.Object>	readerId()
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.
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState>	receiveBuffers()
scala.Option<ActorRef>	reliableDeliverySupervisor()
RemoteMetrics	remoteMetrics()
void	scheduleBackoffTimer()
void	sendBufferedMessages()
int	smallBackoffCount()
AssociationHandle.DisassociateInfo	stopReason()
OneForOneStrategy	supervisorStrategy() User overridable definition the strategy to use for supervising child actors.
void	unhandled(java.lang.Object message) User overridable callback.
int	writeCount()
boolean	writeSend(EndpointManager.Send s)
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	writing()

Methods inherited from class akka.remote.EndpointActor

codec, eventPublisher, localAddress, publishDisassociated, publishError, remoteAddress, settings, transport

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface akka.actor.Actor

aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, preRestart, self, sender

Methods inherited from interface akka.actor.ActorLogging

_log, log

Constructor Detail

EndpointWriter

public EndpointWriter(scala.Option<AkkaProtocolHandle> handleOrActive,
                      Address localAddress,
                      Address remoteAddress,
                      scala.Option<java.lang.Object> refuseUid,
                      AkkaProtocolTransport transport,
                      RemoteSettings settings,
                      AkkaPduCodec codec,
                      java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers,
                      scala.Option<ActorRef> reliableDeliverySupervisor)

Method Detail

props

public static Props props(scala.Option<AkkaProtocolHandle> handleOrActive,
                          Address localAddress,
                          Address remoteAddress,
                          scala.Option<java.lang.Object> refuseUid,
                          AkkaProtocolTransport transport,
                          RemoteSettings settings,
                          AkkaPduCodec codec,
                          java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers,
                          scala.Option<ActorRef> reliableDeliverySupervisor)

receiveBuffers

public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()

reliableDeliverySupervisor

public scala.Option<ActorRef> reliableDeliverySupervisor()

extendedSystem

public ExtendedActorSystem extendedSystem()

remoteMetrics

public RemoteMetrics remoteMetrics()

backoffDispatcher

public MessageDispatcher backoffDispatcher()

reader

public scala.Option<ActorRef> reader()

handle

public scala.Option<AkkaProtocolHandle> handle()

readerId

public scala.collection.Iterator<java.lang.Object> readerId()

newAckDeadline

public scala.concurrent.duration.Deadline newAckDeadline()

ackDeadline

public scala.concurrent.duration.Deadline ackDeadline()

lastAck

public scala.Option<Ack> lastAck()

supervisorStrategy

public OneForOneStrategy supervisorStrategy()

Description copied from interface: Actor

User overridable definition the strategy to use for supervising child actors.

Returns:

(undocumented)

provider

public RemoteActorRefProvider provider()

msgDispatch

public DefaultMessageDispatcher msgDispatch()

inbound

public boolean inbound()

Specified by:

inbound in class EndpointActor

stopReason

public AssociationHandle.DisassociateInfo stopReason()

buffer

public java.util.LinkedList<java.lang.Object> buffer()

prioBuffer

public java.util.LinkedList<EndpointManager.Send> prioBuffer()

largeBufferLogTimestamp

public long largeBufferLogTimestamp()

ackIdleTimer

public Cancellable ackIdleTimer()

preStart

public void preStart()

Description copied from interface: Actor

User overridable callback.

Is called when an Actor is started. Actors are automatically started asynchronously when created. Empty default implementation.

postRestart

public void postRestart(java.lang.Throwable reason)

Description copied from interface: Actor

User overridable callback: By default it calls preStart().

Parameters:

reason - the Throwable that caused the restart to happen

Is called right AFTER restart on the newly created Actor to allow reinitialization after an Actor crash.

postStop

public void postStop()

Description copied from interface: Actor

User overridable callback.

Is called asynchronously after 'actor.stop()' is invoked. Empty default implementation.

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.

Returns:

(undocumented)

initializing

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> initializing()

enqueueInBuffer

public void enqueueInBuffer(java.lang.Object msg)

buffering

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> buffering()

becomeWritingOrSendBufferedMessages

public void becomeWritingOrSendBufferedMessages()

writeCount

public int writeCount()

maxWriteCount

public int maxWriteCount()

adaptiveBackoffNanos

public long adaptiveBackoffNanos()

fullBackoff

public boolean fullBackoff()

fullBackoffCount

public int fullBackoffCount()

smallBackoffCount

public int smallBackoffCount()

noBackoffCount

public int noBackoffCount()

adjustAdaptiveBackup

public void adjustAdaptiveBackup()

sendBufferedMessages

public void sendBufferedMessages()

scheduleBackoffTimer

public void scheduleBackoffTimer()

writing

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> writing()

writeSend

public boolean writeSend(EndpointManager.Send s)

handoff

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> handoff()

unhandled

public void unhandled(java.lang.Object message)

Description copied from interface: Actor

User overridable callback.

Is called when a message isn't handled by the current behavior of the actor by default it fails with either a DeathPactException (in case of an unhandled Terminated message) or publishes an UnhandledMessage to the actor's system's EventStream

Parameters:

message - (undocumented)

flushAndStop

public void flushAndStop()