Package org.apache.pekko.http.impl.settings

Class ConnectionPoolSettingsImpl

java.lang.Object

org.apache.pekko.http.javadsl.settings.ConnectionPoolSettings

org.apache.pekko.http.scaladsl.settings.ConnectionPoolSettings

org.apache.pekko.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(com.typesafe.config.Config config)
static T	apply(String configOverrides)
static T	apply(org.apache.pekko.actor.ActorSystem system)
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
ConnectionPoolSettings	withBaseConnectionBackoff(Duration newValue)	Java API
ConnectionPoolSettings	withIdleTimeout(Duration newValue)	Java API
ConnectionPoolSettings	withKeepAliveTimeout(Duration newValue)	Java API
ConnectionPoolSettings	withMaxConnectionBackoff(Duration newValue)	Java API
ConnectionPoolSettings	withMaxConnectionLifetime(Duration newValue)	Java API
ConnectionPoolSettingsImpl	withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f)

Methods inherited from class org.apache.pekko.http.scaladsl.settings.ConnectionPoolSettings

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

Methods inherited from class org.apache.pekko.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(org.apache.pekko.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

withBaseConnectionBackoff

public ConnectionPoolSettings withBaseConnectionBackoff(Duration newValue)

Description copied from class: ConnectionPoolSettings

Java API

Specified by:

withBaseConnectionBackoff in class ConnectionPoolSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

withMaxConnectionBackoff

public ConnectionPoolSettings withMaxConnectionBackoff(Duration newValue)

Description copied from class: ConnectionPoolSettings

Java API

Specified by:

withMaxConnectionBackoff in class ConnectionPoolSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

withIdleTimeout

public ConnectionPoolSettings withIdleTimeout(Duration newValue)

Description copied from class: ConnectionPoolSettings

Java API

Specified by:

withIdleTimeout in class ConnectionPoolSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

withKeepAliveTimeout

public ConnectionPoolSettings withKeepAliveTimeout(Duration newValue)

Description copied from class: ConnectionPoolSettings

Java API

Specified by:

withKeepAliveTimeout in class ConnectionPoolSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

withMaxConnectionLifetime

public ConnectionPoolSettings withMaxConnectionLifetime(Duration newValue)

Description copied from class: ConnectionPoolSettings

Java API

Specified by:

withMaxConnectionLifetime in class ConnectionPoolSettings

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

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