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 java.lang.Object

Public API but not intended for subclassing

Constructor Summary

Constructors

Constructor and Description
ConnectionPoolSettings()

Method Summary

Modifier and Type	Method and Description
ConnectionPoolSettings	appendHostOverride(java.lang.String hostPattern, ConnectionPoolSettings settings)
static ConnectionPoolSettings	create(org.apache.pekko.actor.ActorSystem system)
static ConnectionPoolSettings	create(com.typesafe.config.Config config)
static ConnectionPoolSettings	create(java.lang.String configOverrides)
scala.concurrent.duration.FiniteDuration	getBaseConnectionBackoff()
ClientConnectionSettings	getConnectionSettings()
scala.concurrent.duration.Duration	getIdleTimeout()
scala.concurrent.duration.Duration	getKeepAliveTimeout()
scala.concurrent.duration.FiniteDuration	getMaxConnectionBackoff()
java.time.Duration	getMaxConnectionLifetime()
int	getMaxConnections()
int	getMaxOpenRequests()
int	getMaxRetries()
int	getMinConnections()
int	getPipeliningLimit()
scala.concurrent.duration.Duration	getResponseEntitySubscriptionTimeout()
abstract ConnectionPoolSettings	withBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)
ConnectionPoolSettings	withConnectionSettings(ClientConnectionSettings newValue)
ConnectionPoolSettings	withHostOverrides(java.util.List<scala.Tuple2<java.lang.String,ConnectionPoolSettings>> hostOverrides)
abstract ConnectionPoolSettings	withIdleTimeout(scala.concurrent.duration.Duration newValue)
abstract ConnectionPoolSettings	withKeepAliveTimeout(scala.concurrent.duration.Duration newValue)
abstract ConnectionPoolSettings	withMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)
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 Detail

ConnectionPoolSettings

public ConnectionPoolSettings()

Method Detail

create

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

create

public static ConnectionPoolSettings create(java.lang.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 java.time.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(java.util.List<scala.Tuple2<java.lang.String,ConnectionPoolSettings>> hostOverrides)

appendHostOverride

public ConnectionPoolSettings appendHostOverride(java.lang.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)

withMaxConnectionBackoff

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

withIdleTimeout

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

withKeepAliveTimeout

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

withMaxConnectionLifetime

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

withConnectionSettings

public ConnectionPoolSettings withConnectionSettings(ClientConnectionSettings newValue)

withResponseEntitySubscriptionTimeout

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

withTransport

public ConnectionPoolSettings withTransport(ClientTransport newValue)