public class EndpointWriter extends EndpointActor
Modifier and Type | Class and Description |
---|---|
static class |
EndpointWriter.AckIdleCheckTimer$ |
static class |
EndpointWriter.BackoffTimer$ |
static class |
EndpointWriter.FlushAndStop$ |
static class |
EndpointWriter.Handle |
static class |
EndpointWriter.Handle$ |
static class |
EndpointWriter.OutboundAck |
static class |
EndpointWriter.OutboundAck$ |
static class |
EndpointWriter.StoppedReading |
static class |
EndpointWriter.StoppedReading$ |
static class |
EndpointWriter.StopReading |
static class |
EndpointWriter.StopReading$ |
static class |
EndpointWriter.TakeOver
This message signals that the current association maintained by the local EndpointWriter and EndpointReader is
to be overridden by a new inbound association.
|
static class |
EndpointWriter.TakeOver$ |
static class |
EndpointWriter.TookOver |
static class |
EndpointWriter.TookOver$ |
Constructor and Description |
---|
EndpointWriter(scala.Option<AkkaProtocolHandle> handleOrActive,
akka.actor.Address localAddress,
akka.actor.Address remoteAddress,
scala.Option<java.lang.Object> refuseUid,
AkkaProtocolTransport transport,
RemoteSettings settings,
AkkaPduCodec codec,
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers,
scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor) |
Modifier and Type | Method and Description |
---|---|
scala.concurrent.duration.Deadline |
ackDeadline() |
akka.actor.Cancellable |
ackIdleTimer() |
long |
adaptiveBackoffNanos() |
void |
adjustAdaptiveBackup() |
akka.dispatch.MessageDispatcher |
backoffDispatcher() |
void |
becomeWritingOrSendBufferedMessages() |
java.util.LinkedList<java.lang.Object> |
buffer() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
buffering() |
void |
enqueueInBuffer(java.lang.Object msg) |
akka.actor.ExtendedActorSystem |
extendedSystem() |
void |
flushAndStop() |
boolean |
fullBackoff() |
int |
fullBackoffCount() |
scala.Option<AkkaProtocolHandle> |
handle() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
handoff() |
boolean |
inbound() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
initializing() |
long |
largeBufferLogTimestamp() |
scala.Option<Ack> |
lastAck() |
int |
maxWriteCount() |
DefaultMessageDispatcher |
msgDispatch() |
scala.concurrent.duration.Deadline |
newAckDeadline() |
int |
noBackoffCount() |
void |
postRestart(java.lang.Throwable reason) |
void |
postStop() |
void |
preStart() |
java.util.LinkedList<EndpointManager.Send> |
prioBuffer() |
static akka.actor.Props |
props(scala.Option<AkkaProtocolHandle> handleOrActive,
akka.actor.Address localAddress,
akka.actor.Address remoteAddress,
scala.Option<java.lang.Object> refuseUid,
AkkaProtocolTransport transport,
RemoteSettings settings,
AkkaPduCodec codec,
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers,
scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor) |
RemoteActorRefProvider |
provider() |
scala.Option<akka.actor.ActorRef> |
reader() |
scala.collection.Iterator<java.lang.Object> |
readerId() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> |
receiveBuffers() |
scala.Option<akka.actor.ActorRef> |
reliableDeliverySupervisor() |
RemoteMetrics |
remoteMetrics() |
void |
scheduleBackoffTimer() |
void |
sendBufferedMessages() |
int |
smallBackoffCount() |
AssociationHandle.DisassociateInfo |
stopReason() |
akka.actor.OneForOneStrategy |
supervisorStrategy() |
void |
unhandled(java.lang.Object message) |
int |
writeCount() |
boolean |
writeSend(EndpointManager.Send s) |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
writing() |
codec, eventPublisher, localAddress, publishDisassociated, publishError, remoteAddress, settings, transport
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public EndpointWriter(scala.Option<AkkaProtocolHandle> handleOrActive, akka.actor.Address localAddress, akka.actor.Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers, scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor)
public static akka.actor.Props props(scala.Option<AkkaProtocolHandle> handleOrActive, akka.actor.Address localAddress, akka.actor.Address remoteAddress, scala.Option<java.lang.Object> refuseUid, AkkaProtocolTransport transport, RemoteSettings settings, AkkaPduCodec codec, java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers, scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor)
public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()
public scala.Option<akka.actor.ActorRef> reliableDeliverySupervisor()
public akka.actor.ExtendedActorSystem extendedSystem()
public RemoteMetrics remoteMetrics()
public akka.dispatch.MessageDispatcher backoffDispatcher()
public scala.Option<akka.actor.ActorRef> reader()
public scala.Option<AkkaProtocolHandle> handle()
public scala.collection.Iterator<java.lang.Object> readerId()
public scala.concurrent.duration.Deadline newAckDeadline()
public scala.concurrent.duration.Deadline ackDeadline()
public scala.Option<Ack> lastAck()
public akka.actor.OneForOneStrategy supervisorStrategy()
public RemoteActorRefProvider provider()
public DefaultMessageDispatcher msgDispatch()
public boolean inbound()
inbound
in class EndpointActor
public AssociationHandle.DisassociateInfo stopReason()
public java.util.LinkedList<java.lang.Object> buffer()
public java.util.LinkedList<EndpointManager.Send> prioBuffer()
public long largeBufferLogTimestamp()
public akka.actor.Cancellable ackIdleTimer()
public void preStart()
public void postRestart(java.lang.Throwable reason)
public void postStop()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> initializing()
public void enqueueInBuffer(java.lang.Object msg)
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> buffering()
public void becomeWritingOrSendBufferedMessages()
public int writeCount()
public int maxWriteCount()
public long adaptiveBackoffNanos()
public boolean fullBackoff()
public int fullBackoffCount()
public int smallBackoffCount()
public int noBackoffCount()
public void adjustAdaptiveBackup()
public void sendBufferedMessages()
public void scheduleBackoffTimer()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> writing()
public boolean writeSend(EndpointManager.Send s)
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> handoff()
public void unhandled(java.lang.Object message)
public void flushAndStop()