public abstract class ConnectionPoolSettings
extends java.lang.Object
Constructor and Description |
---|
ConnectionPoolSettings() |
public static ConnectionPoolSettings create(com.typesafe.config.Config config)
public static ConnectionPoolSettings create(java.lang.String configOverrides)
public static ConnectionPoolSettings create(akka.actor.ActorSystem system)
public int getMaxConnections()
public int getMinConnections()
public int getMaxRetries()
public int getMaxOpenRequests()
public int getPipeliningLimit()
public java.time.Duration getMaxConnectionLifetime()
public scala.concurrent.duration.FiniteDuration getBaseConnectionBackoff()
public scala.concurrent.duration.FiniteDuration getMaxConnectionBackoff()
public scala.concurrent.duration.Duration getIdleTimeout()
public ClientConnectionSettings getConnectionSettings()
public scala.concurrent.duration.Duration getResponseEntitySubscriptionTimeout()
public ConnectionPoolSettings withHostOverrides(java.util.List<scala.Tuple2<java.lang.String,ConnectionPoolSettings>> hostOverrides)
public ConnectionPoolSettings appendHostOverride(java.lang.String hostPattern, ConnectionPoolSettings settings)
public abstract ConnectionPoolSettings withMaxConnections(int n)
public abstract ConnectionPoolSettings withMinConnections(int n)
public abstract ConnectionPoolSettings withMaxRetries(int n)
public abstract ConnectionPoolSettings withMaxOpenRequests(int newValue)
public abstract ConnectionPoolSettings withPipeliningLimit(int newValue)
public abstract ConnectionPoolSettings withBaseConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)
public abstract ConnectionPoolSettings withMaxConnectionBackoff(scala.concurrent.duration.FiniteDuration newValue)
public abstract ConnectionPoolSettings withIdleTimeout(scala.concurrent.duration.Duration newValue)
public abstract ConnectionPoolSettings withMaxConnectionLifetime(scala.concurrent.duration.Duration newValue)
public ConnectionPoolSettings withConnectionSettings(ClientConnectionSettings newValue)
public abstract ConnectionPoolSettings withResponseEntitySubscriptionTimeout(scala.concurrent.duration.Duration newValue)
public ConnectionPoolSettings withTransport(ClientTransport newValue)