Package akka.http.impl.settings

Class ConnectionPoolSettingsImpl

java.lang.Object

akka.http.javadsl.settings.ConnectionPoolSettings

akka.http.scaladsl.settings.ConnectionPoolSettings

akka.http.impl.settings.ConnectionPoolSettingsImpl

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public final class ConnectionPoolSettingsImpl
extends ConnectionPoolSettings
implements scala.Product, Serializable

INTERNAL API

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor

Description

ConnectionPoolSettingsImpl(int maxConnections, int minConnections, int maxRetries, int maxOpenRequests, int pipeliningLimit, scala.concurrent.duration.Duration maxConnectionLifetime, scala.concurrent.duration.FiniteDuration baseConnectionBackoff, scala.concurrent.duration.FiniteDuration maxConnectionBackoff, scala.concurrent.duration.Duration idleTimeout, scala.concurrent.duration.Duration keepAliveTimeout, ClientConnectionSettings connectionSettings, scala.concurrent.duration.Duration responseEntitySubscriptionTimeout, scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> hostOverrides)

Method Summary

Modifier and Type	Method	Description
static T	apply(akka.actor.ActorSystem system)
static T	apply(com.typesafe.config.Config config)
static T	apply(String configOverrides)
scala.concurrent.duration.FiniteDuration	baseConnectionBackoff()
ClientConnectionSettings	connectionSettings()
ConnectionPoolSettings	copyDeep(scala.Function1<ConnectionPoolSettings,ConnectionPoolSettings> mapHostOverrides, int maxConnections, int minConnections, int maxRetries, int maxOpenRequests, int pipeliningLimit, scala.concurrent.duration.Duration maxConnectionLifetime, scala.concurrent.duration.FiniteDuration baseConnectionBackoff, scala.concurrent.duration.FiniteDuration maxConnectionBackoff, scala.concurrent.duration.Duration idleTimeout, scala.concurrent.duration.Duration keepAliveTimeout, ClientConnectionSettings connectionSettings, scala.concurrent.duration.Duration responseEntitySubscriptionTimeout)	INTERNAL API
static ConnectionPoolSettingsImpl	fromSubConfig(com.typesafe.config.Config root, com.typesafe.config.Config c)
scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>>	hostOverrides()
static scala.util.matching.Regex	hostRegex(String pattern)
scala.concurrent.duration.Duration	idleTimeout()
scala.concurrent.duration.Duration	keepAliveTimeout()
scala.concurrent.duration.FiniteDuration	maxConnectionBackoff()
scala.concurrent.duration.Duration	maxConnectionLifetime()
int	maxConnections()
int	maxOpenRequests()
int	maxRetries()
int	minConnections()
int	pipeliningLimit()
protected static String	prefix()
String	productPrefix()
scala.concurrent.duration.Duration	responseEntitySubscriptionTimeout()	The time after which the pool will drop an entity automatically if it wasn't read or discarded
ConnectionPoolSettingsImpl	withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f)

Methods inherited from class akka.http.scaladsl.settings.ConnectionPoolSettings

appendHostOverride, forHost, transport, withBaseConnectionBackoff, withConnectionSettings, withHostOverrides, withIdleTimeout, withKeepAliveTimeout, withMaxConnectionBackoff, withMaxConnectionLifetime, withMaxConnections, withMaxOpenRequests, withMaxRetries, withMinConnections, withPipeliningLimit, withResponseEntitySubscriptionTimeout, withTransport

Methods inherited from class akka.http.javadsl.settings.ConnectionPoolSettings

appendHostOverride, create, create, create, getBaseConnectionBackoff, getConnectionSettings, getIdleTimeout, getKeepAliveTimeout, getMaxConnectionBackoff, getMaxConnectionLifetime, getMaxConnections, getMaxOpenRequests, getMaxRetries, getMinConnections, getPipeliningLimit, getResponseEntitySubscriptionTimeout, withConnectionSettings, withHostOverrides, withTransport

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator

Constructor Details

ConnectionPoolSettingsImpl

public ConnectionPoolSettingsImpl(int maxConnections,
 int minConnections,
 int maxRetries,
 int maxOpenRequests,
 int pipeliningLimit,
 scala.concurrent.duration.Duration maxConnectionLifetime,
 scala.concurrent.duration.FiniteDuration baseConnectionBackoff,
 scala.concurrent.duration.FiniteDuration maxConnectionBackoff,
 scala.concurrent.duration.Duration idleTimeout,
 scala.concurrent.duration.Duration keepAliveTimeout,
 ClientConnectionSettings connectionSettings,
 scala.concurrent.duration.Duration responseEntitySubscriptionTimeout,
 scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> hostOverrides)

Method Details

fromSubConfig

public static ConnectionPoolSettingsImpl fromSubConfig(com.typesafe.config.Config root,
 com.typesafe.config.Config c)

hostRegex

public static scala.util.matching.Regex hostRegex(String pattern)

prefix

protected static String prefix()

apply

public static T apply(akka.actor.ActorSystem system)

apply

public static T apply(String configOverrides)

apply

public static T apply(com.typesafe.config.Config config)

maxConnections

public int maxConnections()

Specified by:

maxConnections in class ConnectionPoolSettings

minConnections

public int minConnections()

Specified by:

minConnections in class ConnectionPoolSettings

maxRetries

public int maxRetries()

Specified by:

maxRetries in class ConnectionPoolSettings

maxOpenRequests

public int maxOpenRequests()

Specified by:

maxOpenRequests in class ConnectionPoolSettings

pipeliningLimit

public int pipeliningLimit()

Specified by:

pipeliningLimit in class ConnectionPoolSettings

maxConnectionLifetime

public scala.concurrent.duration.Duration maxConnectionLifetime()

Specified by:

maxConnectionLifetime in class ConnectionPoolSettings

baseConnectionBackoff

public scala.concurrent.duration.FiniteDuration baseConnectionBackoff()

Specified by:

baseConnectionBackoff in class ConnectionPoolSettings

maxConnectionBackoff

public scala.concurrent.duration.FiniteDuration maxConnectionBackoff()

Specified by:

maxConnectionBackoff in class ConnectionPoolSettings

idleTimeout

public scala.concurrent.duration.Duration idleTimeout()

Specified by:

idleTimeout in class ConnectionPoolSettings

keepAliveTimeout

public scala.concurrent.duration.Duration keepAliveTimeout()

Specified by:

keepAliveTimeout in class ConnectionPoolSettings

connectionSettings

public ClientConnectionSettings connectionSettings()

Specified by:

connectionSettings in class ConnectionPoolSettings

responseEntitySubscriptionTimeout

public scala.concurrent.duration.Duration responseEntitySubscriptionTimeout()

Description copied from class: ConnectionPoolSettings

The time after which the pool will drop an entity automatically if it wasn't read or discarded

Specified by:

responseEntitySubscriptionTimeout in class ConnectionPoolSettings

hostOverrides

public scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> hostOverrides()

Specified by:

hostOverrides in class ConnectionPoolSettings

productPrefix

public String productPrefix()

Specified by:

productPrefix in interface scala.Product

withUpdatedConnectionSettings

public ConnectionPoolSettingsImpl withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f)

Specified by:

withUpdatedConnectionSettings in class ConnectionPoolSettings

copyDeep

public ConnectionPoolSettings copyDeep(scala.Function1<ConnectionPoolSettings,ConnectionPoolSettings> mapHostOverrides,
 int maxConnections,
 int minConnections,
 int maxRetries,
 int maxOpenRequests,
 int pipeliningLimit,
 scala.concurrent.duration.Duration maxConnectionLifetime,
 scala.concurrent.duration.FiniteDuration baseConnectionBackoff,
 scala.concurrent.duration.FiniteDuration maxConnectionBackoff,
 scala.concurrent.duration.Duration idleTimeout,
 scala.concurrent.duration.Duration keepAliveTimeout,
 ClientConnectionSettings connectionSettings,
 scala.concurrent.duration.Duration responseEntitySubscriptionTimeout)

INTERNAL API