public final class ConnectionPoolSettingsImpl extends ConnectionPoolSettings implements scala.Product, scala.Serializable
Constructor and Description |
---|
ConnectionPoolSettingsImpl(int maxConnections,
int minConnections,
int maxRetries,
int maxOpenRequests,
int pipeliningLimit,
scala.concurrent.duration.Duration maxConnectionLifetime,
scala.concurrent.duration.FiniteDuration baseConnectionBackoff,
scala.concurrent.duration.FiniteDuration maxConnectionBackoff,
scala.concurrent.duration.Duration idleTimeout,
scala.concurrent.duration.Duration keepAliveTimeout,
ClientConnectionSettings connectionSettings,
PoolImplementation poolImplementation,
scala.concurrent.duration.Duration responseEntitySubscriptionTimeout) |
Modifier and Type | Method and Description |
---|---|
static T |
apply(akka.actor.ActorSystem system) |
static T |
apply(com.typesafe.config.Config config) |
static T |
apply(java.lang.String configOverrides) |
scala.concurrent.duration.FiniteDuration |
baseConnectionBackoff() |
ClientConnectionSettings |
connectionSettings() |
static ConnectionPoolSettingsImpl |
fromSubConfig(com.typesafe.config.Config root,
com.typesafe.config.Config c) |
scala.concurrent.duration.Duration |
idleTimeout() |
scala.concurrent.duration.Duration |
keepAliveTimeout() |
scala.concurrent.duration.FiniteDuration |
maxConnectionBackoff() |
scala.concurrent.duration.Duration |
maxConnectionLifetime() |
int |
maxConnections() |
int |
maxOpenRequests() |
int |
maxRetries() |
int |
minConnections() |
int |
pipeliningLimit() |
PoolImplementation |
poolImplementation() |
protected static java.lang.String |
prefix() |
java.lang.String |
productPrefix() |
scala.concurrent.duration.Duration |
responseEntitySubscriptionTimeout()
The time after which the pool will drop an entity automatically if it wasn't read or discarded
|
ConnectionPoolSettingsImpl |
withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f) |
transport, withBaseConnectionBackoff, withConnectionSettings, withIdleTimeout, withKeepAliveTimeout, withMaxConnectionBackoff, withMaxConnectionLifetime, withMaxConnections, withMaxOpenRequests, withMaxRetries, withMinConnections, withPipeliningLimit, withPoolImplementation, withResponseEntitySubscriptionTimeout, withTransport
create, create, create, getBaseConnectionBackoff, getConnectionSettings, getIdleTimeout, getKeepAliveTimeout, getMaxConnectionBackoff, getMaxConnections, getMaxOpenRequests, getMaxRetries, getMinConnections, getPipeliningLimit, getPoolImplementation, getResponseEntitySubscriptionTimeout, getTransport, withConnectionSettings, withPoolImplementation, withTransport
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public ConnectionPoolSettingsImpl(int maxConnections, int minConnections, int maxRetries, int maxOpenRequests, int pipeliningLimit, scala.concurrent.duration.Duration maxConnectionLifetime, scala.concurrent.duration.FiniteDuration baseConnectionBackoff, scala.concurrent.duration.FiniteDuration maxConnectionBackoff, scala.concurrent.duration.Duration idleTimeout, scala.concurrent.duration.Duration keepAliveTimeout, ClientConnectionSettings connectionSettings, PoolImplementation poolImplementation, scala.concurrent.duration.Duration responseEntitySubscriptionTimeout)
public static ConnectionPoolSettingsImpl fromSubConfig(com.typesafe.config.Config root, com.typesafe.config.Config c)
protected static java.lang.String prefix()
public static T apply(akka.actor.ActorSystem system)
public static T apply(java.lang.String configOverrides)
public static T apply(com.typesafe.config.Config config)
public int maxConnections()
maxConnections
in class ConnectionPoolSettings
public int minConnections()
minConnections
in class ConnectionPoolSettings
public int maxRetries()
maxRetries
in class ConnectionPoolSettings
public int maxOpenRequests()
maxOpenRequests
in class ConnectionPoolSettings
public int pipeliningLimit()
pipeliningLimit
in class ConnectionPoolSettings
public scala.concurrent.duration.Duration maxConnectionLifetime()
maxConnectionLifetime
in class ConnectionPoolSettings
public scala.concurrent.duration.FiniteDuration baseConnectionBackoff()
baseConnectionBackoff
in class ConnectionPoolSettings
public scala.concurrent.duration.FiniteDuration maxConnectionBackoff()
maxConnectionBackoff
in class ConnectionPoolSettings
public scala.concurrent.duration.Duration idleTimeout()
idleTimeout
in class ConnectionPoolSettings
public scala.concurrent.duration.Duration keepAliveTimeout()
keepAliveTimeout
in class ConnectionPoolSettings
public ClientConnectionSettings connectionSettings()
connectionSettings
in class ConnectionPoolSettings
public PoolImplementation poolImplementation()
poolImplementation
in class ConnectionPoolSettings
public scala.concurrent.duration.Duration responseEntitySubscriptionTimeout()
ConnectionPoolSettings
responseEntitySubscriptionTimeout
in class ConnectionPoolSettings
public java.lang.String productPrefix()
productPrefix
in interface scala.Product
public ConnectionPoolSettingsImpl withUpdatedConnectionSettings(scala.Function1<ClientConnectionSettings,ClientConnectionSettings> f)
withUpdatedConnectionSettings
in class ConnectionPoolSettings