public final class PoolMasterActor
extends java.lang.Object
implements akka.actor.Actor, akka.actor.ActorLogging
Manages access to a host connection pool or rather: a sequence of pool incarnations.
A host connection pool for a given HostConnectionPoolSetup
is a running stream, whose outside interface is
provided by its PoolInterfaceActor
actor. The actor accepts PoolInterfaceActor.PoolRequest
messages
and completes their responsePromise
whenever the respective response has been received (or an error occurred).
The PoolMasterActor
provides a layer of indirection between a PoolGateway
, which represents a pool,
and the PoolInterfaceActor
instances which are created on-demand and stopped after an idle-timeout.
Several PoolGateway
objects may be mapped to the same pool if they have the same HostConnectionPoolSetup
and are marked as being shared. This is the case for example for gateways obtained through
HttpExt.cachedHostConnectionPool
. Some other gateways are not shared, such as those obtained through
HttpExt.newHostConnectionPool
, and will have their dedicated restartable pool.
Modifier and Type | Class and Description |
---|---|
static class |
PoolMasterActor.PoolInterfaceRunning |
static class |
PoolMasterActor.PoolInterfaceRunning$ |
static class |
PoolMasterActor.PoolInterfaceShuttingDown |
static class |
PoolMasterActor.PoolInterfaceShuttingDown$ |
static interface |
PoolMasterActor.PoolInterfaceStatus |
static class |
PoolMasterActor.PoolSize |
static class |
PoolMasterActor.PoolSize$ |
static class |
PoolMasterActor.PoolStatus |
static class |
PoolMasterActor.PoolStatus$ |
static class |
PoolMasterActor.SendRequest |
static class |
PoolMasterActor.SendRequest$ |
static class |
PoolMasterActor.Shutdown |
static class |
PoolMasterActor.Shutdown$ |
static class |
PoolMasterActor.ShutdownAll |
static class |
PoolMasterActor.ShutdownAll$ |
static class |
PoolMasterActor.StartPool |
static class |
PoolMasterActor.StartPool$ |
Constructor and Description |
---|
PoolMasterActor() |
Modifier and Type | Method and Description |
---|---|
akka.actor.ActorContext |
context() |
static akka.actor.Props |
props() |
scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> |
receive() |
akka.actor.ActorRef |
self() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
$init$, akka$actor$Actor$_setter_$context_$eq, akka$actor$Actor$_setter_$self_$eq, aroundPostRestart, aroundPostStop, aroundPreRestart, aroundPreStart, aroundReceive, noSender, postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled
public static akka.actor.Props props()
public akka.actor.ActorContext context()
context
in interface akka.actor.Actor
public final akka.actor.ActorRef self()
self
in interface akka.actor.Actor
public scala.PartialFunction<java.lang.Object,scala.runtime.BoxedUnit> receive()
receive
in interface akka.actor.Actor