Package akka.remote

Class EndpointReader

java.lang.Object

akka.remote.EndpointActor

akka.remote.EndpointReader

All Implemented Interfaces:

Actor, ActorLogging

public class EndpointReader
extends EndpointActor

INTERNAL API

Nested Class Summary

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

Actor.emptyBehavior$, Actor.ignoringBehavior$

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
AckedReceiveBuffer<AkkaPduCodec.Message>	ackedReceiveBuffer()
void	ackedReceiveBuffer_$eq(AckedReceiveBuffer<AkkaPduCodec.Message> x$1)
boolean	inbound()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	notReading()
void	postStop()	User overridable callback.
void	preStart()	User overridable callback.
static Props	props(Address localAddress, Address remoteAddress, Transport transport, RemoteSettings settings, AkkaPduCodec codec, InboundMessageDispatcher msgDispatch, boolean inbound, int uid, scala.Option<ActorRef> reliableDeliverySupervisor, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers)
RemoteActorRefProvider	provider()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	receive()	Scala API: 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()
void	saveState()
int	uid()

Methods inherited from class akka.remote.EndpointActor

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, codec, context, eventPublisher, localAddress, publishDisassociated, publishError, remoteAddress, self, 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, postRestart, preRestart, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.ActorLogging

_log_$eq, log

Constructor Detail

EndpointReader

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

Method Detail

props

public static Props props(Address localAddress,
                          Address remoteAddress,
                          Transport transport,
                          RemoteSettings settings,
                          AkkaPduCodec codec,
                          InboundMessageDispatcher msgDispatch,
                          boolean inbound,
                          int uid,
                          scala.Option<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<ActorRef> reliableDeliverySupervisor()

receiveBuffers

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

provider

public RemoteActorRefProvider provider()

ackedReceiveBuffer

public AckedReceiveBuffer<AkkaPduCodec.Message> ackedReceiveBuffer()

ackedReceiveBuffer_$eq

public void ackedReceiveBuffer_$eq(AckedReceiveBuffer<AkkaPduCodec.Message> x$1)

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.

postStop

public void postStop()

Description copied from interface: Actor

User overridable callback.

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

saveState

public void saveState()

receive

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

Description copied from interface: Actor

Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.

Returns:

(undocumented)

notReading

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