public class EndpointManager
extends java.lang.Object
implements akka.actor.Actor, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>
Constructor and Description |
---|
EndpointManager(com.typesafe.config.Config conf,
akka.event.LoggingAdapter log) |
Modifier and Type | Method and Description |
---|---|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
accepting() |
scala.collection.Iterator<java.lang.Object> |
endpointId() |
EndpointManager.EndpointRegistry |
endpoints() |
EventPublisher |
eventPublisher() |
akka.actor.ExtendedActorSystem |
extendedSystem() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
flushing() |
void |
handleInboundAssociation(Transport.InboundAssociation ia,
boolean writerIsIdle) |
void |
handleStashedInbound(akka.actor.ActorRef endpoint,
boolean writerIsIdle) |
void |
keepQuarantinedOr(akka.actor.Address remoteAddress,
scala.Function0<scala.runtime.BoxedUnit> body) |
scala.collection.immutable.Map<akka.actor.ActorRef,AkkaProtocolHandle> |
pendingReadHandoffs() |
void |
postStop() |
scala.concurrent.duration.FiniteDuration |
pruneInterval() |
scala.Option<akka.actor.Cancellable> |
pruneTimerCancellable() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> |
receiveBuffers() |
boolean |
retryGateEnabled() |
RemoteSettings |
settings() |
scala.collection.immutable.Map<akka.actor.ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>> |
stashedInbound() |
akka.actor.OneForOneStrategy |
supervisorStrategy() |
scala.collection.immutable.Map<akka.actor.Address,AkkaProtocolTransport> |
transportMapping() |
public EndpointManager(com.typesafe.config.Config conf, akka.event.LoggingAdapter log)
public RemoteSettings settings()
public akka.actor.ExtendedActorSystem extendedSystem()
public scala.collection.Iterator<java.lang.Object> endpointId()
public EventPublisher eventPublisher()
public EndpointManager.EndpointRegistry endpoints()
public scala.collection.immutable.Map<akka.actor.Address,AkkaProtocolTransport> transportMapping()
public boolean retryGateEnabled()
public scala.concurrent.duration.FiniteDuration pruneInterval()
public scala.Option<akka.actor.Cancellable> pruneTimerCancellable()
public scala.collection.immutable.Map<akka.actor.ActorRef,AkkaProtocolHandle> pendingReadHandoffs()
public scala.collection.immutable.Map<akka.actor.ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>> stashedInbound()
public void handleStashedInbound(akka.actor.ActorRef endpoint, boolean writerIsIdle)
public void keepQuarantinedOr(akka.actor.Address remoteAddress, scala.Function0<scala.runtime.BoxedUnit> body)
public akka.actor.OneForOneStrategy supervisorStrategy()
supervisorStrategy
in interface akka.actor.Actor
public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> accepting()
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> flushing()
public void handleInboundAssociation(Transport.InboundAssociation ia, boolean writerIsIdle)
public void postStop()
postStop
in interface akka.actor.Actor