akka.remote
Class EndpointWriter

java.lang.Object
  extended by akka.remote.EndpointActor
      extended by 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()