Package 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
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface akka.actor.Actor
Actor.emptyBehavior$, Actor.ignoringBehavior$
-
-
Constructor Summary
Constructors Constructor Description EndpointManager(com.typesafe.config.Config conf, LoggingAdapter log)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
accepting()
protected void
akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
protected void
akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
The 'self' field holds the ActorRef for this actor.ActorContext
context()
Scala API: Stores the context for this actor, including self, and sender.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
pendingReadHandoffs_$eq(scala.collection.immutable.Map<ActorRef,AkkaProtocolHandle> x$1)
void
postStop()
User overridable callback.scala.concurrent.duration.FiniteDuration
pruneInterval()
Cancellable
pruneTimerCancellable()
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit>
receive()
Scala API: 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()
ActorRef
self()
The 'self' field holds the ActorRef for this actor.RemoteSettings
settings()
scala.collection.immutable.Map<ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>>
stashedInbound()
void
stashedInbound_$eq(scala.collection.immutable.Map<ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>> x$1)
OneForOneStrategy
supervisorStrategy()
User overridable definition the strategy to use for supervising child actors.scala.collection.immutable.Map<Address,AkkaProtocolTransport>
transportMapping()
void
transportMapping_$eq(scala.collection.immutable.Map<Address,AkkaProtocolTransport> x$1)
-
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, postRestart, preRestart, preStart, sender, unhandled
-
-
-
-
Constructor Detail
-
EndpointManager
public EndpointManager(com.typesafe.config.Config conf, LoggingAdapter log)
-
-
Method Detail
-
context
public ActorContext context()
Description copied from interface:Actor
Scala API: Stores the context for this actor, including self, and sender. It is implicit to support operations such asforward
.WARNING: Only valid within the Actor itself, so do not close over it and publish it to other threads!
ActorContext
is the Scala API.getContext
returns aAbstractActor.ActorContext
, which is the Java API of the actor context.
-
self
public final ActorRef self()
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
-
akka$actor$Actor$_setter_$context_$eq
protected void akka$actor$Actor$_setter_$context_$eq(ActorContext x$1)
- Specified by:
akka$actor$Actor$_setter_$context_$eq
in interfaceActor
-
akka$actor$Actor$_setter_$self_$eq
protected final void akka$actor$Actor$_setter_$self_$eq(ActorRef x$1)
Description copied from interface:Actor
The 'self' field holds the ActorRef for this actor. Can be used to send messages to itself:self ! message
- Specified by:
akka$actor$Actor$_setter_$self_$eq
in interfaceActor
- Parameters:
x$1
- (undocumented)
-
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()
-
transportMapping_$eq
public void transportMapping_$eq(scala.collection.immutable.Map<Address,AkkaProtocolTransport> x$1)
-
pruneInterval
public scala.concurrent.duration.FiniteDuration pruneInterval()
-
pruneTimerCancellable
public Cancellable pruneTimerCancellable()
-
pendingReadHandoffs
public scala.collection.immutable.Map<ActorRef,AkkaProtocolHandle> pendingReadHandoffs()
-
pendingReadHandoffs_$eq
public void pendingReadHandoffs_$eq(scala.collection.immutable.Map<ActorRef,AkkaProtocolHandle> x$1)
-
stashedInbound
public scala.collection.immutable.Map<ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>> stashedInbound()
-
stashedInbound_$eq
public void stashedInbound_$eq(scala.collection.immutable.Map<ActorRef,scala.collection.immutable.Vector<Transport.InboundAssociation>> x$1)
-
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 interfaceActor
- 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
Scala API: This defines the initial actor behavior, it must return a partial function with the actor logic.
-
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)
-
-