akka.remote
Class EndpointReader

java.lang.Object
  extended by akka.remote.EndpointActor
      extended by 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$
 
Constructor Summary
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
 AckedReceiveBuffer<AkkaPduCodec.Message> ackedReceiveBuffer()
           
 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()
          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
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, postRestart, preRestart, self, sender, supervisorStrategy, unhandled
 
Methods inherited from interface akka.actor.ActorLogging
_log, 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()

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
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()