public class EndpointReader extends EndpointActor
Actor.emptyBehavior$, Actor.ignoringBehavior$
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) |
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) |
codec, context, eventPublisher, localAddress, publishDisassociated, publishError, remoteAddress, self, settings, transport
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, postRestart, preRestart, sender, supervisorStrategy, unhandled
log
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)
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)
public static final ActorRef sender()
protected static void aroundReceive(scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive, java.lang.Object msg)
protected static void aroundPreStart()
protected static void aroundPostStop()
protected static void aroundPreRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message)
protected static void aroundPostRestart(java.lang.Throwable reason)
public static SupervisorStrategy supervisorStrategy()
public static void preRestart(java.lang.Throwable reason, scala.Option<java.lang.Object> message) throws java.lang.Exception
java.lang.Exception
public static void postRestart(java.lang.Throwable reason) throws java.lang.Exception
java.lang.Exception
public static void unhandled(java.lang.Object message)
public static LoggingAdapter log()
public static Address localAddress()
public static Address remoteAddress()
public static Transport transport()
public static RemoteSettings settings()
public static AkkaPduCodec codec()
public static EventPublisher eventPublisher()
public static void publishError(java.lang.Throwable reason, Logging.LogLevel logLevel)
public static void publishDisassociated()
public static LoggingAdapter akka$actor$ActorLogging$$_log()
public static void akka$actor$ActorLogging$$_log_$eq(LoggingAdapter x$1)
public static ActorContext context()
public static final ActorRef self()
protected static void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected static final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
public boolean inbound()
inbound
in class EndpointActor
public int uid()
public scala.Option<ActorRef> reliableDeliverySupervisor()
public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()
public RemoteActorRefProvider provider()
public AckedReceiveBuffer<AkkaPduCodec.Message> ackedReceiveBuffer()
public void preStart()
Actor
public void postStop()
Actor
public void saveState()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> notReading()