public class EndpointReader extends EndpointActor
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
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() |
codec, eventPublisher, localAddress, publishDisassociated, publishError, remoteAddress, settings, transport
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
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)
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)
public boolean inbound()
inbound
in class EndpointActor
public int uid()
public scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor()
public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()
public RemoteActorRefProvider provider()
public AckedReceiveBuffer<AkkaPduCodec.Message> ackedReceiveBuffer()
public void preStart()
public void postStop()
public void saveState()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> notReading()