akka.remote
Class EndpointWriter

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

All Implemented Interfaces:

akka.actor.Actor, akka.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

akka.actor.Actor.emptyBehavior$

Constructor Summary

EndpointWriter(scala.Option<AkkaProtocolHandle> handleOrActive, akka.actor.Address localAddress, akka.actor.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<akka.actor.ActorRef> reliableDeliverySupervisor)

Method Summary

scala.concurrent.duration.Deadline	ackDeadline()
akka.actor.Cancellable	ackIdleTimer()
long	adaptiveBackoffNanos()
void	adjustAdaptiveBackup()
akka.dispatch.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)
akka.actor.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)
void	postStop()
void	preStart()
java.util.LinkedList<EndpointManager.Send>	prioBuffer()
static akka.actor.Props	props(scala.Option<AkkaProtocolHandle> handleOrActive, akka.actor.Address localAddress, akka.actor.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<akka.actor.ActorRef> reliableDeliverySupervisor)
RemoteActorRefProvider	provider()
scala.Option<akka.actor.ActorRef>	reader()
scala.collection.Iterator<java.lang.Object>	readerId()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState>	receiveBuffers()
scala.Option<akka.actor.ActorRef>	reliableDeliverySupervisor()
RemoteMetrics	remoteMetrics()
void	scheduleBackoffTimer()
void	sendBufferedMessages()
int	smallBackoffCount()
AssociationHandle.DisassociateInfo	stopReason()
akka.actor.OneForOneStrategy	supervisorStrategy()
void	unhandled(java.lang.Object message)
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

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, preRestart, self, sender

Methods inherited from interface akka.actor.ActorLogging

akka$actor$ActorLogging$$_log_$eq, akka$actor$ActorLogging$$_log, log

Constructor Detail

EndpointWriter

public EndpointWriter(scala.Option<AkkaProtocolHandle> handleOrActive,
                      akka.actor.Address localAddress,
                      akka.actor.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<akka.actor.ActorRef> reliableDeliverySupervisor)

Method Detail

props

public static akka.actor.Props props(scala.Option<AkkaProtocolHandle> handleOrActive,
                                     akka.actor.Address localAddress,
                                     akka.actor.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<akka.actor.ActorRef> reliableDeliverySupervisor)

receiveBuffers

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

reliableDeliverySupervisor

public scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor()

extendedSystem

public akka.actor.ExtendedActorSystem extendedSystem()

remoteMetrics

public RemoteMetrics remoteMetrics()

backoffDispatcher

public akka.dispatch.MessageDispatcher backoffDispatcher()

reader

public scala.Option<akka.actor.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 akka.actor.OneForOneStrategy supervisorStrategy()

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 akka.actor.Cancellable ackIdleTimer()

preStart

public void preStart()

postRestart

public void postRestart(java.lang.Throwable reason)

postStop

public void postStop()

receive

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

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)

flushAndStop

public void flushAndStop()