Class ConnectionPoolSettings
java.lang.Object
org.apache.pekko.http.javadsl.settings.ConnectionPoolSettings
- Direct Known Subclasses:
- ConnectionPoolSettings
Public API but not intended for subclassing
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionappendHostOverride(String hostPattern, ConnectionPoolSettings settings) static ConnectionPoolSettingscreate(com.typesafe.config.Config config) static ConnectionPoolSettingsstatic ConnectionPoolSettingscreate(org.apache.pekko.actor.ActorSystem system) In 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.In 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.In 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.In 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.intintintintintIn 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.abstract ConnectionPoolSettingswithBaseConnectionBackoff(Duration newValue) Java APIabstract ConnectionPoolSettingswithBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue) withHostOverrides(List<scala.Tuple2<String, ConnectionPoolSettings>> hostOverrides) abstract ConnectionPoolSettingswithIdleTimeout(Duration newValue) Java APIabstract ConnectionPoolSettingswithIdleTimeout(scala.concurrent.duration.Duration newValue) abstract ConnectionPoolSettingswithKeepAliveTimeout(Duration newValue) Java APIabstract ConnectionPoolSettingswithKeepAliveTimeout(scala.concurrent.duration.Duration newValue) abstract ConnectionPoolSettingswithMaxConnectionBackoff(Duration newValue) Java APIabstract ConnectionPoolSettingswithMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue) abstract ConnectionPoolSettingswithMaxConnectionLifetime(Duration newValue) Java APIabstract ConnectionPoolSettingswithMaxConnectionLifetime(scala.concurrent.duration.Duration newValue) abstract ConnectionPoolSettingswithMaxConnections(int n) abstract ConnectionPoolSettingswithMaxOpenRequests(int newValue) abstract ConnectionPoolSettingswithMaxRetries(int n) abstract ConnectionPoolSettingswithMinConnections(int n) abstract ConnectionPoolSettingswithPipeliningLimit(int newValue) Client-side pipelining is not currently supported, see https://github.com/akka/akka-http/issues/32abstract ConnectionPoolSettingsJava APIabstract ConnectionPoolSettingswithResponseEntitySubscriptionTimeout(scala.concurrent.duration.Duration newValue) withTransport(ClientTransport newValue) 
- 
Constructor Details- 
ConnectionPoolSettingspublic ConnectionPoolSettings()
 
- 
- 
Method Details- 
create
- 
create
- 
create
- 
getMaxConnectionspublic int getMaxConnections()
- 
getMinConnectionspublic int getMinConnections()
- 
getMaxRetriespublic int getMaxRetries()
- 
getMaxOpenRequestspublic int getMaxOpenRequests()
- 
getPipeliningLimitpublic int getPipeliningLimit()
- 
getMaxConnectionLifetime
- 
getBaseConnectionBackoffIn 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.- Returns:
- (undocumented)
 
- 
getMaxConnectionBackoffIn 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.- Returns:
- (undocumented)
 
- 
getIdleTimeoutIn 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.- Returns:
- (undocumented)
 
- 
getKeepAliveTimeoutIn 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.- Returns:
- (undocumented)
 
- 
getConnectionSettings
- 
getResponseEntitySubscriptionTimeoutIn 2.0.0, the return type of this method changed fromscala.concurrent.duration.FiniteDurationtojava.time.Duration.- Returns:
- (undocumented)
 
- 
withHostOverridespublic ConnectionPoolSettings withHostOverrides(List<scala.Tuple2<String, ConnectionPoolSettings>> hostOverrides) 
- 
appendHostOverridepublic ConnectionPoolSettings appendHostOverride(String hostPattern, ConnectionPoolSettings settings) 
- 
withMaxConnections
- 
withMinConnections
- 
withMaxRetries
- 
withMaxOpenRequests
- 
withPipeliningLimitClient-side pipelining is not currently supported, see https://github.com/akka/akka-http/issues/32
- 
withBaseConnectionBackoffpublic abstract ConnectionPoolSettings withBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue) 
- 
withBaseConnectionBackoffJava API- Parameters:
- newValue- (undocumented)
- Returns:
- (undocumented)
- Since:
- 1.3.0
 
- 
withMaxConnectionBackoffpublic abstract ConnectionPoolSettings withMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue) 
- 
withMaxConnectionBackoffJava API- Parameters:
- newValue- (undocumented)
- Returns:
- (undocumented)
- Since:
- 1.3.0
 
- 
withIdleTimeout
- 
withIdleTimeoutJava API- Parameters:
- newValue- (undocumented)
- Returns:
- (undocumented)
- Since:
- 1.3.0
 
- 
withKeepAliveTimeoutpublic abstract ConnectionPoolSettings withKeepAliveTimeout(scala.concurrent.duration.Duration newValue) 
- 
withKeepAliveTimeoutJava API- Parameters:
- newValue- (undocumented)
- Returns:
- (undocumented)
- Since:
- 1.3.0
 
- 
withMaxConnectionLifetimepublic abstract ConnectionPoolSettings withMaxConnectionLifetime(scala.concurrent.duration.Duration newValue) 
- 
withMaxConnectionLifetimeJava API- Parameters:
- newValue- (undocumented)
- Returns:
- (undocumented)
- Since:
- 1.3.0
 
- 
withConnectionSettings
- 
withResponseEntitySubscriptionTimeoutpublic abstract ConnectionPoolSettings withResponseEntitySubscriptionTimeout(scala.concurrent.duration.Duration newValue) 
- 
withResponseEntitySubscriptionTimeoutJava API- Parameters:
- newValue- (undocumented)
- Returns:
- (undocumented)
- Since:
- 1.3.0
 
- 
withTransport
 
-