E
- endpoint address type, for example SocketAddress
for TCP and UDP transportspublic static class MultiEndpointPool.Builder<E> extends Object
SingleEndpointPool
.Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
MultiEndpointPool<E> |
build()
Constructs
MultiEndpointPool . |
MultiEndpointPool.Builder<E> |
connectorHandler(ConnectorHandler<E> defaultConnectorHandler)
Sets the default
ConnectorHandler to be used to establish new
Connection s if none is specified by EndpointKey . |
MultiEndpointPool.Builder<E> |
connectTimeout(long connectTimeout,
TimeUnit timeunit)
Sets the max time
Connection connect operation may take. |
MultiEndpointPool.Builder<E> |
delayExecutor(DelayedExecutor delayedExecutor)
Sets the custom
DelayedExecutor to be used for keep-alive and
reconnect mechanisms. |
MultiEndpointPool.Builder<E> |
keepAliveCheckInterval(long keepAliveCheckInterval,
TimeUnit timeunit)
Sets the interval, which specifies how often the pool will perform
idle
Connection s check. |
MultiEndpointPool.Builder<E> |
keepAliveTimeout(long keepAliveTimeout,
TimeUnit timeunit)
Sets the maximum number of milliseconds an idle
Connection
will be kept in the pool. |
MultiEndpointPool.Builder<E> |
maxConnectionsPerEndpoint(int maxConnectionsPerEndpoint)
Sets the maximum number of
Connection s to a single endpoint
the pool is allowed to have. |
MultiEndpointPool.Builder<E> |
maxConnectionsTotal(int maxConnectionsTotal)
Sets the maximum number of
Connection s the pool is allowed to have. |
MultiEndpointPool.Builder<E> |
maxReconnectAttempts(int maxReconnectAttempts)
If the reconnect mechanism is enabled, then this property will affect
how many times a reconnection attempt can be made consecutively before
a failure is flagged.
|
MultiEndpointPool.Builder<E> |
reconnectDelay(long reconnectDelay,
TimeUnit timeunit)
Sets the delay to be used before the pool will repeat the attempt to
connect to the endpoint after previous connect operation had failed.
|
public MultiEndpointPool.Builder<E> connectorHandler(ConnectorHandler<E> defaultConnectorHandler)
ConnectorHandler
to be used to establish new
Connection
s if none is specified by EndpointKey
.defaultConnectorHandler
- ConnectorHandler
SingleEndpointPool.Builder
public MultiEndpointPool.Builder<E> maxConnectionsPerEndpoint(int maxConnectionsPerEndpoint)
Connection
s to a single endpoint
the pool is allowed to have.
Default value is 2.maxConnectionsPerEndpoint
- SingleEndpointPool.Builder
public MultiEndpointPool.Builder<E> maxConnectionsTotal(int maxConnectionsTotal)
Connection
s the pool is allowed to have.
Default value is 16.maxConnectionsTotal
- SingleEndpointPool.Builder
public MultiEndpointPool.Builder<E> delayExecutor(DelayedExecutor delayedExecutor)
DelayedExecutor
to be used for keep-alive and
reconnect mechanisms.
If none is set - the SingleEndpointPool
will create its own DelayedExecutor
.delayedExecutor
- SingleEndpointPool.Builder
public MultiEndpointPool.Builder<E> connectTimeout(long connectTimeout, TimeUnit timeunit)
Connection
connect operation may take.
If timeout expires - the connect operation is considered failed.
If connectTimeout < 0 - the connect timeout mechanism will be disabled.
By default the connect timeout mechanism is disabled.connectTimeout
- the max time Connection
connect
operation may take. If timeout expires - the connect operation
is considered failed. The negative value disables the
connect timeout mechanism.timeunit
- a TimeUnit determining how to interpret the
timeout parameterSingleEndpointPool.Builder
public MultiEndpointPool.Builder<E> reconnectDelay(long reconnectDelay, TimeUnit timeunit)
reconnectDelay
- the delay to be used before the pool will repeat
the attempt to connect to the endpoint after previous connect
operation had failed. The negative value disables the
reconnect mechanism.timeunit
- a TimeUnit determining how to interpret the
timeout parameterSingleEndpointPool.Builder
public MultiEndpointPool.Builder<E> maxReconnectAttempts(int maxReconnectAttempts)
maxReconnectAttempts
- the maximum number of reconnect attempts.
If the reconnect mechanism isn't enabled, this property is ignored.SingleEndpointPool.Builder
public MultiEndpointPool.Builder<E> keepAliveTimeout(long keepAliveTimeout, TimeUnit timeunit)
Connection
will be kept in the pool.
The idle Connection
s will be closed till the pool size is
greater than corePoolSize.
If keepAliveTimeout < 0 - the keep-alive mechanism will be disabled.
By default the keep-alive timeout is set to 30 seconds.keepAliveTimeout
- the maximum number of milliseconds an idle
Connection
will be kept in the pool. The negative
value disables the keep-alive mechanism.timeunit
- a TimeUnit determining how to interpret the
timeout parameterSingleEndpointPool.Builder
public MultiEndpointPool.Builder<E> keepAliveCheckInterval(long keepAliveCheckInterval, TimeUnit timeunit)
Connection
s check.keepAliveCheckInterval
- the interval, which specifies how often the
pool will perform idle Connection
s checktimeunit
- a TimeUnit determining how to interpret the
timeout parameterSingleEndpointPool.Builder
public MultiEndpointPool<E> build()
MultiEndpointPool
.MultiEndpointPool
Copyright © 2014 Oracle Corporation. All rights reserved.