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 and 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 and Description
AckedReceiveBuffer<AkkaPduCodec.Message>	ackedReceiveBuffer()
protected static void	akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected static void	akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
static void	akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
static LoggingAdapter	akka$actor$ActorLogging$$_log()
protected static void	aroundPostRestart(java.lang.Throwable reason)
protected static void	aroundPostStop()
protected static void	aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void	aroundPreStart()
protected static void	aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
static AkkaPduCodec	codec()
static ActorContext	context()
static EventPublisher	eventPublisher()
boolean	inbound()
static Address	localAddress()
static LoggingAdapter	log()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>	notReading()
static void	postRestart(java.lang.Throwable reason)
void	postStop() User overridable callback.
static void	preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
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()
static void	publishDisassociated()
static void	publishError(java.lang.Throwable reason, Logging.LogLevel logLevel)
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()
static Address	remoteAddress()
void	saveState()
static ActorRef	self()
static ActorRef	sender()
static RemoteSettings	settings()
static SupervisorStrategy	supervisorStrategy()
static Transport	transport()
int	uid()
static void	unhandled(java.lang.Object message)

Methods inherited from class akka.remote.EndpointActor

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

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)

sender

public static final ActorRef sender()

aroundReceive

protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive,
                                    java.lang.Object msg)

aroundPreStart

protected static void aroundPreStart()

aroundPostStop

protected static void aroundPostStop()

aroundPreRestart

protected static void aroundPreRestart(java.lang.Throwable reason,
                                       scala.Option<java.lang.Object> message)

aroundPostRestart

protected static void aroundPostRestart(java.lang.Throwable reason)

supervisorStrategy

public static SupervisorStrategy supervisorStrategy()

preRestart

public static void preRestart(java.lang.Throwable reason,
                              scala.Option<java.lang.Object> message)
                       throws java.lang.Exception

Throws:

java.lang.Exception

postRestart

public static void postRestart(java.lang.Throwable reason)
                        throws java.lang.Exception

Throws:

java.lang.Exception

unhandled

public static void unhandled(java.lang.Object message)

log

public static LoggingAdapter log()

localAddress

public static Address localAddress()

remoteAddress

public static Address remoteAddress()

transport

public static Transport transport()

settings

public static RemoteSettings settings()

codec

public static AkkaPduCodec codec()

eventPublisher

public static EventPublisher eventPublisher()

publishError

public static void publishError(java.lang.Throwable reason,
                                Logging.LogLevel logLevel)

publishDisassociated

public static void publishDisassociated()

akka$actor$ActorLogging$$_log

public static LoggingAdapter akka$actor$ActorLogging$$_log()

akka$actor$ActorLogging$$_log_$eq

public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)

context

public static ActorContext context()

self

public static final ActorRef self()

akka$actor$Actor$_setter_$context_$eq

protected static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)

akka$actor$Actor$_setter_$self_$eq

protected static final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)

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