akka.remote
Class EndpointManager
java.lang.Object
akka.remote.EndpointManager
- All Implemented Interfaces:
- Actor, RequiresMessageQueue<UnboundedMessageQueueSemantics>
public class EndpointManager
- extends java.lang.Object
- implements Actor, RequiresMessageQueue<UnboundedMessageQueueSemantics>
INTERNAL API
Method Summary |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
accepting()
|
scala.collection.Iterator<java.lang.Object> |
endpointId()
|
EndpointManager.EndpointRegistry |
endpoints()
|
EventPublisher |
eventPublisher()
|
ExtendedActorSystem |
extendedSystem()
|
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
flushing()
|
void |
handleInboundAssociation(Transport.InboundAssociation ia,
boolean writerIsIdle)
|
void |
handleStashedInbound(ActorRef endpoint,
boolean writerIsIdle)
|
void |
keepQuarantinedOr(Address remoteAddress,
scala.Function0<scala.runtime.BoxedUnit> body)
|
scala.collection.immutable.Map<ActorRef,AkkaProtocolHandle> |
pendingReadHandoffs()
|
void |
postStop()
User overridable callback. |
scala.concurrent.duration.FiniteDuration |
pruneInterval()
|
Cancellable |
pruneTimerCancellable()
|
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()
|
RemoteSettings |
settings()
|
scala.collection.immutable.Map<ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>> |
stashedInbound()
|
OneForOneStrategy |
supervisorStrategy()
User overridable definition the strategy to use for supervising
child actors. |
scala.collection.immutable.Map<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 |
aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, context, postRestart, preRestart, preStart, self, sender, unhandled |
EndpointManager
public EndpointManager(com.typesafe.config.Config conf,
LoggingAdapter log)
settings
public RemoteSettings settings()
extendedSystem
public 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<Address,AkkaProtocolTransport> transportMapping()
pruneInterval
public scala.concurrent.duration.FiniteDuration pruneInterval()
pruneTimerCancellable
public Cancellable pruneTimerCancellable()
pendingReadHandoffs
public scala.collection.immutable.Map<ActorRef,AkkaProtocolHandle> pendingReadHandoffs()
stashedInbound
public scala.collection.immutable.Map<ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>> stashedInbound()
handleStashedInbound
public void handleStashedInbound(ActorRef endpoint,
boolean writerIsIdle)
keepQuarantinedOr
public void keepQuarantinedOr(Address remoteAddress,
scala.Function0<scala.runtime.BoxedUnit> body)
supervisorStrategy
public OneForOneStrategy supervisorStrategy()
- Description copied from interface:
Actor
- User overridable definition the strategy to use for supervising
child actors.
- Specified by:
supervisorStrategy
in interface Actor
- Returns:
- (undocumented)
receiveBuffers
public java.util.concurrent.ConcurrentHashMap<EndpointManager.Link,EndpointManager.ResendState> receiveBuffers()
receive
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
- Description copied from interface:
Actor
- This defines the initial actor behavior, it must return a partial function
with the actor logic.
- Specified by:
receive
in interface Actor
- Returns:
- (undocumented)
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()
- Description copied from interface:
Actor
- User overridable callback.
Is called asynchronously after 'actor.stop()' is invoked.
Empty default implementation.
- Specified by:
postStop
in interface Actor