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 idleTimeout,
ClientConnectionSettings connectionSettings,
PoolImplementation poolImplementation,
scala.concurrent.duration.Duration responseEntitySubscriptionTimeout) |
ConnectionPoolSettingsImpl(int maxConnections,
int minConnections,
int maxRetries,
int maxOpenRequests,
int pipeliningLimit,
scala.concurrent.duration.Duration idleTimeout,
ClientConnectionSettings connectionSettings,
PoolImplementation poolImplementation,
scala.concurrent.duration.Duration responseEntitySubscriptionTimeout,
ClientTransport transport) |
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) |
ClientConnectionSettings |
connectionSettings() |
static ConnectionPoolSettingsImpl |
fromSubConfig(com.typesafe.config.Config root,
com.typesafe.config.Config c) |
scala.concurrent.duration.Duration |
idleTimeout() |
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
|
ClientTransport |
transport()
The underlying transport used to connect to hosts.
|
withConnectionSettings, withIdleTimeout, withMaxConnections, withMaxOpenRequests, withMaxRetries, withMinConnections, withPipeliningLimit, withPoolImplementation, withResponseEntitySubscriptionTimeout, withTransport
create, create, create, getConnectionSettings, getIdleTimeout, 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 idleTimeout, ClientConnectionSettings connectionSettings, PoolImplementation poolImplementation, scala.concurrent.duration.Duration responseEntitySubscriptionTimeout, ClientTransport transport)
public ConnectionPoolSettingsImpl(int maxConnections, int minConnections, int maxRetries, int maxOpenRequests, int pipeliningLimit, scala.concurrent.duration.Duration idleTimeout, 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 idleTimeout()
idleTimeout
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 ClientTransport transport()
ConnectionPoolSettings
ClientTransport.TCP
is used.transport
in class ConnectionPoolSettings
public java.lang.String productPrefix()
productPrefix
in interface scala.Product