akka.remote
Class EndpointManager

java.lang.Object
  akka.remote.EndpointManager

All Implemented Interfaces:

akka.actor.Actor, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>

public class EndpointManager
extends java.lang.Object
implements akka.actor.Actor, akka.dispatch.RequiresMessageQueue<akka.dispatch.UnboundedMessageQueueSemantics>

INTERNAL API

Nested Class Summary

static interface	EndpointManager.EndpointPolicy
static class	EndpointManager.EndpointRegistry
static class	EndpointManager.Gated
static class	EndpointManager.Gated$
static class	EndpointManager.Link
static class	EndpointManager.Link$
static class	EndpointManager.Listen
static class	EndpointManager.Listen$
static class	EndpointManager.ListensFailure
static class	EndpointManager.ListensFailure$
static class	EndpointManager.ListensResult
static class	EndpointManager.ListensResult$
static class	EndpointManager.ManagementCommand
static class	EndpointManager.ManagementCommand$
static class	EndpointManager.ManagementCommandAck
static class	EndpointManager.ManagementCommandAck$
static class	EndpointManager.Pass
static class	EndpointManager.Pass$
static class	EndpointManager.Prune$
static class	EndpointManager.Quarantine
static class	EndpointManager.Quarantine$
static class	EndpointManager.Quarantined
static class	EndpointManager.Quarantined$
static interface	EndpointManager.RemotingCommand
static class	EndpointManager.ResendState
static class	EndpointManager.ResendState$
static class	EndpointManager.Send
static class	EndpointManager.Send$
static class	EndpointManager.ShutdownAndFlush$
static class	EndpointManager.StartupFinished$

Nested classes/interfaces inherited from interface akka.actor.Actor

akka.actor.Actor.emptyBehavior$

Constructor Summary

EndpointManager(com.typesafe.config.Config conf, akka.event.LoggingAdapter log)

Method Summary

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

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

akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, unhandled

Constructor Detail

EndpointManager

public EndpointManager(com.typesafe.config.Config conf,
                       akka.event.LoggingAdapter log)

Method Detail

settings

public RemoteSettings settings()

extendedSystem

public akka.actor.ExtendedActorSystem extendedSystem()

endpointId

public scala.collection.Iterator<java.lang.Object> endpointId()

eventPublisher

public EventPublisher eventPublisher()

endpoints

public EndpointManager.EndpointRegistry endpoints()

transportMapping

public scala.collection.immutable.Map<akka.actor.Address,AkkaProtocolTransport> transportMapping()

retryGateEnabled

public boolean retryGateEnabled()

pruneInterval

public scala.concurrent.duration.FiniteDuration pruneInterval()

pruneTimerCancellable

public scala.Option<akka.actor.Cancellable> pruneTimerCancellable()

pendingReadHandoffs

public scala.collection.immutable.Map<akka.actor.ActorRef,AkkaProtocolHandle> pendingReadHandoffs()

stashedInbound

public scala.collection.immutable.Map<akka.actor.ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>> stashedInbound()

handleStashedInbound

public void handleStashedInbound(akka.actor.ActorRef endpoint,
                                 boolean writerIsIdle)

keepQuarantinedOr

public void keepQuarantinedOr(akka.actor.Address remoteAddress,
                              scala.Function0<scala.runtime.BoxedUnit> body)

supervisorStrategy

public akka.actor.OneForOneStrategy supervisorStrategy()

Specified by:

supervisorStrategy in interface akka.actor.Actor

receiveBuffers

public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()

receive

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()

Specified by:

receive in interface akka.actor.Actor

accepting

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> accepting()

flushing

public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> flushing()

handleInboundAssociation

public void handleInboundAssociation(Transport.InboundAssociation ia,
                                     boolean writerIsIdle)

postStop

public void postStop()

Specified by:

postStop in interface akka.actor.Actor