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 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 Duration getBaseConnectionBackoff()
      In 2.0.0, the return type of this method changed from scala.concurrent.duration.FiniteDuration to java.time.Duration.
      Returns:
      (undocumented)

    • getMaxConnectionBackoff

      public Duration getMaxConnectionBackoff()
      In 2.0.0, the return type of this method changed from scala.concurrent.duration.FiniteDuration to java.time.Duration.
      Returns:
      (undocumented)

    • getIdleTimeout

      public Duration getIdleTimeout()
      In 2.0.0, the return type of this method changed from scala.concurrent.duration.FiniteDuration to java.time.Duration.
      Returns:
      (undocumented)

    • getKeepAliveTimeout

      public Duration getKeepAliveTimeout()
      In 2.0.0, the return type of this method changed from scala.concurrent.duration.FiniteDuration to java.time.Duration.
      Returns:
      (undocumented)

    • getConnectionSettings

      public ClientConnectionSettings getConnectionSettings()

    • getResponseEntitySubscriptionTimeout

      public Duration getResponseEntitySubscriptionTimeout()
      In 2.0.0, the return type of this method changed from scala.concurrent.duration.FiniteDuration to java.time.Duration.
      Returns:
      (undocumented)

    • 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)

    • withResponseEntitySubscriptionTimeout

      public abstract ConnectionPoolSettings withResponseEntitySubscriptionTimeout(Duration newValue)
      Java API
      Parameters:
      newValue - (undocumented)
      Returns:
      (undocumented)
      Since:
      1.3.0

    • withTransport

      public ConnectionPoolSettings withTransport(ClientTransport newValue)