Package org.apache.pekko.http.javadsl.settings

Class ConnectionPoolSettings

java.lang.Object

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

Direct Known Subclasses:

ConnectionPoolSettings

public abstract class ConnectionPoolSettings
extends Object

Public API but not intended for subclassing

Constructor Summary

Constructors

Constructor	Description
ConnectionPoolSettings()

Method Summary

Modifier and Type	Method	Description
ConnectionPoolSettings	appendHostOverride(String hostPattern, ConnectionPoolSettings settings)
static ConnectionPoolSettings	create(com.typesafe.config.Config config)
static ConnectionPoolSettings	create(String configOverrides)
static ConnectionPoolSettings	create(org.apache.pekko.actor.ActorSystem system)
scala.concurrent.duration.FiniteDuration	getBaseConnectionBackoff()
ClientConnectionSettings	getConnectionSettings()
scala.concurrent.duration.Duration	getIdleTimeout()
scala.concurrent.duration.Duration	getKeepAliveTimeout()
scala.concurrent.duration.FiniteDuration	getMaxConnectionBackoff()
Duration	getMaxConnectionLifetime()
int	getMaxConnections()
int	getMaxOpenRequests()
int	getMaxRetries()
int	getMinConnections()
int	getPipeliningLimit()
scala.concurrent.duration.Duration	getResponseEntitySubscriptionTimeout()
abstract ConnectionPoolSettings	withBaseConnectionBackoff(Duration newValue)	Java API
abstract ConnectionPoolSettings	withBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)
ConnectionPoolSettings	withConnectionSettings(ClientConnectionSettings newValue)
ConnectionPoolSettings	withHostOverrides(List<scala.Tuple2<String,ConnectionPoolSettings>> hostOverrides)
abstract ConnectionPoolSettings	withIdleTimeout(Duration newValue)	Java API
abstract ConnectionPoolSettings	withIdleTimeout(scala.concurrent.duration.Duration newValue)
abstract ConnectionPoolSettings	withKeepAliveTimeout(Duration newValue)	Java API
abstract ConnectionPoolSettings	withKeepAliveTimeout(scala.concurrent.duration.Duration newValue)
abstract ConnectionPoolSettings	withMaxConnectionBackoff(Duration newValue)	Java API
abstract ConnectionPoolSettings	withMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)
abstract ConnectionPoolSettings	withMaxConnectionLifetime(Duration newValue)	Java API
abstract ConnectionPoolSettings	withMaxConnectionLifetime(scala.concurrent.duration.Duration newValue)
abstract ConnectionPoolSettings	withMaxConnections(int n)
abstract ConnectionPoolSettings	withMaxOpenRequests(int newValue)
abstract ConnectionPoolSettings	withMaxRetries(int n)
abstract ConnectionPoolSettings	withMinConnections(int n)
abstract ConnectionPoolSettings	withPipeliningLimit(int newValue)	Client-side pipelining is not currently supported, see https://github.com/akka/akka-http/issues/32
abstract ConnectionPoolSettings	withResponseEntitySubscriptionTimeout(scala.concurrent.duration.Duration newValue)
ConnectionPoolSettings	withTransport(ClientTransport newValue)

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionPoolSettings

public ConnectionPoolSettings()

Method Details

create

public static ConnectionPoolSettings create(com.typesafe.config.Config config)

create

public static ConnectionPoolSettings create(String configOverrides)

create

public static ConnectionPoolSettings create(org.apache.pekko.actor.ActorSystem system)

getMaxConnections

public int getMaxConnections()

getMinConnections

public int getMinConnections()

getMaxRetries

public int getMaxRetries()

getMaxOpenRequests

public int getMaxOpenRequests()

getPipeliningLimit

public int getPipeliningLimit()

getMaxConnectionLifetime

public Duration getMaxConnectionLifetime()

getBaseConnectionBackoff

public scala.concurrent.duration.FiniteDuration getBaseConnectionBackoff()

getMaxConnectionBackoff

public scala.concurrent.duration.FiniteDuration getMaxConnectionBackoff()

getIdleTimeout

public scala.concurrent.duration.Duration getIdleTimeout()

getKeepAliveTimeout

public scala.concurrent.duration.Duration getKeepAliveTimeout()

getConnectionSettings

public ClientConnectionSettings getConnectionSettings()

getResponseEntitySubscriptionTimeout

public scala.concurrent.duration.Duration getResponseEntitySubscriptionTimeout()

withHostOverrides

public ConnectionPoolSettings withHostOverrides(List<scala.Tuple2<String,ConnectionPoolSettings>> hostOverrides)

appendHostOverride

public ConnectionPoolSettings appendHostOverride(String hostPattern,
 ConnectionPoolSettings settings)

withMaxConnections

public abstract ConnectionPoolSettings withMaxConnections(int n)

withMinConnections

public abstract ConnectionPoolSettings withMinConnections(int n)

withMaxRetries

public abstract ConnectionPoolSettings withMaxRetries(int n)

withMaxOpenRequests

public abstract ConnectionPoolSettings withMaxOpenRequests(int newValue)

withPipeliningLimit

public abstract ConnectionPoolSettings withPipeliningLimit(int newValue)

Client-side pipelining is not currently supported, see https://github.com/akka/akka-http/issues/32

withBaseConnectionBackoff

public abstract ConnectionPoolSettings withBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)

withBaseConnectionBackoff

public abstract ConnectionPoolSettings withBaseConnectionBackoff(Duration newValue)

Java API

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

withMaxConnectionBackoff

public abstract ConnectionPoolSettings withMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)

withMaxConnectionBackoff

public abstract ConnectionPoolSettings withMaxConnectionBackoff(Duration newValue)

Java API

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

withIdleTimeout

public abstract ConnectionPoolSettings withIdleTimeout(scala.concurrent.duration.Duration newValue)

withIdleTimeout

public abstract ConnectionPoolSettings withIdleTimeout(Duration newValue)

Java API

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

withKeepAliveTimeout

public abstract ConnectionPoolSettings withKeepAliveTimeout(scala.concurrent.duration.Duration newValue)

withKeepAliveTimeout

public abstract ConnectionPoolSettings withKeepAliveTimeout(Duration newValue)

Java API

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

withMaxConnectionLifetime

public abstract ConnectionPoolSettings withMaxConnectionLifetime(scala.concurrent.duration.Duration newValue)

withMaxConnectionLifetime

public abstract ConnectionPoolSettings withMaxConnectionLifetime(Duration newValue)

Java API

Parameters:

newValue - (undocumented)

Returns:

(undocumented)

Since:

1.3.0

withConnectionSettings

public ConnectionPoolSettings withConnectionSettings(ClientConnectionSettings newValue)

withResponseEntitySubscriptionTimeout

public abstract ConnectionPoolSettings withResponseEntitySubscriptionTimeout(scala.concurrent.duration.Duration newValue)

withTransport

public ConnectionPoolSettings withTransport(ClientTransport newValue)