akka.remote
Class EndpointReader

java.lang.Object
  akka.remote.EndpointActor
      akka.remote.EndpointReader

All Implemented Interfaces:

akka.actor.Actor, akka.actor.ActorLogging

public class EndpointReader
extends EndpointActor

INTERNAL API

Nested Class Summary

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

akka.actor.Actor.emptyBehavior$

Constructor Summary

EndpointReader(akka.actor.Address localAddress, akka.actor.Address remoteAddress, Transport transport, RemoteSettings settings, AkkaPduCodec codec, InboundMessageDispatcher msgDispatch, boolean inbound, int uid, scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)

Method Summary

AckedReceiveBuffer<AkkaPduCodec.Message>	ackedReceiveBuffer()
boolean	inbound()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	notReading()
void	postStop()
void	preStart()
static akka.actor.Props	props(akka.actor.Address localAddress, akka.actor.Address remoteAddress, Transport transport, RemoteSettings settings, AkkaPduCodec codec, InboundMessageDispatcher msgDispatch, boolean inbound, int uid, scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)
RemoteActorRefProvider	provider()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState>	receiveBuffers()
scala.Option<akka.actor.ActorRef>	reliableDeliverySupervisor()
void	saveState()
int	uid()

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, postRestart, preRestart, self, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.ActorLogging

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

Constructor Detail

EndpointReader

public EndpointReader(akka.actor.Address localAddress,
                      akka.actor.Address remoteAddress,
                      Transport transport,
                      RemoteSettings settings,
                      AkkaPduCodec codec,
                      InboundMessageDispatcher msgDispatch,
                      boolean inbound,
                      int uid,
                      scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor,
                      java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)

Method Detail

props

public static akka.actor.Props props(akka.actor.Address localAddress,
                                     akka.actor.Address remoteAddress,
                                     Transport transport,
                                     RemoteSettings settings,
                                     AkkaPduCodec codec,
                                     InboundMessageDispatcher msgDispatch,
                                     boolean inbound,
                                     int uid,
                                     scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor,
                                     java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)

inbound

public boolean inbound()

Specified by:

inbound in class EndpointActor

uid

public int uid()

reliableDeliverySupervisor

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

receiveBuffers

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

provider

public RemoteActorRefProvider provider()

ackedReceiveBuffer

public AckedReceiveBuffer<AkkaPduCodec.Message> ackedReceiveBuffer()

preStart

public void preStart()

postStop

public void postStop()

saveState

public void saveState()

receive

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

notReading

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