Package akka.http.scaladsl.settings
Class ConnectionPoolSettings
java.lang.Object
akka.http.javadsl.settings.ConnectionPoolSettings
akka.http.scaladsl.settings.ConnectionPoolSettings
- Direct Known Subclasses:
ConnectionPoolSettingsImpl
Public API but not intended for subclassing
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionappendHostOverride
(String hostPattern, ConnectionPoolSettings settings) static ConnectionPoolSettingsImpl
apply
(com.typesafe.config.Config config) static ConnectionPoolSettingsImpl
abstract scala.concurrent.duration.FiniteDuration
abstract ClientConnectionSettings
This checks to see if there's a matching host override.abstract scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,
ConnectionPoolSettings>> abstract scala.concurrent.duration.Duration
abstract scala.concurrent.duration.Duration
abstract scala.concurrent.duration.FiniteDuration
abstract scala.concurrent.duration.Duration
abstract int
abstract int
abstract int
abstract int
abstract int
abstract scala.concurrent.duration.Duration
The time after which the pool will drop an entity automatically if it wasn't read or discardedDeprecated.Deprecated in favor of connectionSettings.transport.withBaseConnectionBackoff
(scala.concurrent.duration.FiniteDuration newValue) withHostOverrides
(scala.collection.immutable.Seq<scala.Tuple2<String, ConnectionPoolSettings>> hostOverrides) withIdleTimeout
(scala.concurrent.duration.Duration newValue) withKeepAliveTimeout
(scala.concurrent.duration.Duration newValue) withMaxConnectionBackoff
(scala.concurrent.duration.FiniteDuration newValue) withMaxConnectionLifetime
(scala.concurrent.duration.Duration newValue) withMaxConnections
(int n) withMaxOpenRequests
(int newValue) withMaxRetries
(int n) withMinConnections
(int n) withPipeliningLimit
(int newValue) Client-side pipelining is not currently supported, see https://github.com/akka/akka-http/issues/32withResponseEntitySubscriptionTimeout
(scala.concurrent.duration.Duration newValue) withTransport
(ClientTransport newValue) Since 10.1.0, the transport is configured inClientConnectionSettings
.abstract ConnectionPoolSettings
withUpdatedConnectionSettings
(scala.Function1<ClientConnectionSettings, ClientConnectionSettings> f) 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
-
Constructor Details
-
ConnectionPoolSettings
public ConnectionPoolSettings()
-
-
Method Details
-
apply
-
apply
-
maxConnections
public abstract int maxConnections() -
minConnections
public abstract int minConnections() -
maxRetries
public abstract int maxRetries() -
maxOpenRequests
public abstract int maxOpenRequests() -
pipeliningLimit
public abstract int pipeliningLimit() -
baseConnectionBackoff
public abstract scala.concurrent.duration.FiniteDuration baseConnectionBackoff() -
maxConnectionBackoff
public abstract scala.concurrent.duration.FiniteDuration maxConnectionBackoff() -
idleTimeout
public abstract scala.concurrent.duration.Duration idleTimeout() -
keepAliveTimeout
public abstract scala.concurrent.duration.Duration keepAliveTimeout() -
connectionSettings
-
maxConnectionLifetime
public abstract scala.concurrent.duration.Duration maxConnectionLifetime() -
hostOverrides
public abstract scala.collection.immutable.Seq<scala.Tuple2<scala.util.matching.Regex,ConnectionPoolSettings>> hostOverrides() -
forHost
This checks to see if there's a matching host override. When multiple patterns match, the first matching set of overrides is selected.- Parameters:
host
- (undocumented)- Returns:
- (undocumented)
-
transport
Deprecated.Deprecated in favor of connectionSettings.transport. Since 10.1.0.The underlying transport used to connect to hosts. By defaultClientTransport.TCP
is used.- Returns:
- (undocumented)
-
responseEntitySubscriptionTimeout
public abstract scala.concurrent.duration.Duration responseEntitySubscriptionTimeout()The time after which the pool will drop an entity automatically if it wasn't read or discarded -
withHostOverrides
public ConnectionPoolSettings withHostOverrides(scala.collection.immutable.Seq<scala.Tuple2<String, ConnectionPoolSettings>> hostOverrides) -
appendHostOverride
public ConnectionPoolSettings appendHostOverride(String hostPattern, ConnectionPoolSettings settings) -
withMaxConnections
- Specified by:
withMaxConnections
in classConnectionPoolSettings
-
withMinConnections
- Specified by:
withMinConnections
in classConnectionPoolSettings
-
withMaxRetries
- Specified by:
withMaxRetries
in classConnectionPoolSettings
-
withMaxOpenRequests
- Specified by:
withMaxOpenRequests
in classConnectionPoolSettings
-
withBaseConnectionBackoff
public ConnectionPoolSettings withBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue) - Specified by:
withBaseConnectionBackoff
in classConnectionPoolSettings
-
withMaxConnectionBackoff
public ConnectionPoolSettings withMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue) - Specified by:
withMaxConnectionBackoff
in classConnectionPoolSettings
-
withPipeliningLimit
Description copied from class:ConnectionPoolSettings
Client-side pipelining is not currently supported, see https://github.com/akka/akka-http/issues/32- Specified by:
withPipeliningLimit
in classConnectionPoolSettings
-
withIdleTimeout
- Specified by:
withIdleTimeout
in classConnectionPoolSettings
-
withKeepAliveTimeout
- Specified by:
withKeepAliveTimeout
in classConnectionPoolSettings
-
withMaxConnectionLifetime
public ConnectionPoolSettings withMaxConnectionLifetime(scala.concurrent.duration.Duration newValue) - Specified by:
withMaxConnectionLifetime
in classConnectionPoolSettings
-
withConnectionSettings
-
withResponseEntitySubscriptionTimeout
public ConnectionPoolSettings withResponseEntitySubscriptionTimeout(scala.concurrent.duration.Duration newValue) - Specified by:
withResponseEntitySubscriptionTimeout
in classConnectionPoolSettings
-
withTransport
Since 10.1.0, the transport is configured inClientConnectionSettings
. This method is a shortcut forwithUpdatedConnectionSettings(_.withTransport(newTransport))
.- Parameters:
newValue
- (undocumented)- Returns:
- (undocumented)
-
withUpdatedConnectionSettings
public abstract ConnectionPoolSettings withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings, ClientConnectionSettings> f)
-