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