Package akka.http.impl.engine.client

Class PoolMasterActor

java.lang.Object

akka.http.impl.engine.client.PoolMasterActor

All Implemented Interfaces:

akka.actor.Actor, akka.actor.ActorLogging

public final class PoolMasterActor
extends Object
implements akka.actor.Actor, akka.actor.ActorLogging

INTERNAL API

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 PoolInterface actor. The actor accepts PoolInterface.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 PoolId, which represents a pool, and the PoolInterface instances which are created on-demand and stopped after an idle-timeout.

Several PoolId 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.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	PoolMasterActor.HasBeenShutdown
static class	PoolMasterActor.HasBeenShutdown$
static final class	PoolMasterActor.PoolInterfaceRunning
static class	PoolMasterActor.PoolInterfaceRunning$
static final class	PoolMasterActor.PoolInterfaceShuttingDown
static class	PoolMasterActor.PoolInterfaceShuttingDown$
static interface	PoolMasterActor.PoolInterfaceStatus
static final class	PoolMasterActor.PoolSize
static class	PoolMasterActor.PoolSize$
static final class	PoolMasterActor.PoolStatus
static class	PoolMasterActor.PoolStatus$
static final class	PoolMasterActor.SendRequest
static class	PoolMasterActor.SendRequest$
static final class	PoolMasterActor.Shutdown
static class	PoolMasterActor.Shutdown$
static final class	PoolMasterActor.ShutdownAll
static class	PoolMasterActor.ShutdownAll$
static final class	PoolMasterActor.StartPool
static class	PoolMasterActor.StartPool$

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

akka.actor.Actor.emptyBehavior$, akka.actor.Actor.ignoringBehavior$

Constructor Summary

Constructors

Constructor	Description
PoolMasterActor()

Method Summary

Modifier and Type	Method	Description
akka.actor.ActorContext	context()
static akka.actor.Props	props()
scala.PartialFunction<Object,scala.runtime.BoxedUnit>	receive()
final akka.actor.ActorRef	self()

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, postRestart, postStop, preRestart, preStart, sender, supervisorStrategy, unhandled

Methods inherited from interface akka.actor.ActorLogging

akka$actor$ActorLogging$$_log, akka$actor$ActorLogging$$_log_$eq, log

Constructor Details

PoolMasterActor

public PoolMasterActor()

Method Details

props

public static akka.actor.Props props()

context

public akka.actor.ActorContext context()

Specified by:

context in interface akka.actor.Actor

self

public final akka.actor.ActorRef self()

Specified by:

self in interface akka.actor.Actor

receive

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

Specified by:

receive in interface akka.actor.Actor