public static class ClusterClientOptions.Builder extends ClientOptions.Builder
ClusterClientOptions
.Constructor and Description |
---|
Builder() |
Modifier and Type | Method and Description |
---|---|
ClusterClientOptions.Builder |
autoReconnect(boolean autoReconnect)
Enables or disables auto reconnection on connection loss.
|
ClusterClientOptions |
build()
Create a new instance of
ClusterClientOptions |
ClusterClientOptions.Builder |
cancelCommandsOnReconnectFailure(boolean cancelCommandsOnReconnectFailure)
Allows cancelling queued commands in case a reconnect fails.Defaults to false.
|
ClusterClientOptions.Builder |
closeStaleConnections(boolean closeStaleConnections)
Flag, whether to close stale connections when refreshing the cluster topology.
|
ClusterClientOptions.Builder |
pingBeforeActivateConnection(boolean pingBeforeActivateConnection)
Sets the PING before activate connection flag.
|
ClusterClientOptions.Builder |
refreshClusterView(boolean refreshClusterView)
Enable regular cluster topology updates.
|
ClusterClientOptions.Builder |
refreshPeriod(long refreshPeriod,
TimeUnit refreshPeriodUnit)
Set the refresh period.
|
ClusterClientOptions.Builder |
requestQueueSize(int requestQueueSize)
Set the per-connection request queue size.
|
ClusterClientOptions.Builder |
suspendReconnectOnProtocolFailure(boolean suspendReconnectOnProtocolFailure)
Suspends reconnect when reconnects run into protocol failures (SSL verification, PING before connect fails).
|
ClusterClientOptions.Builder |
validateClusterNodeMembership(boolean validateClusterNodeMembership)
Validate the cluster node membership before allowing connections to a cluster node.
|
public ClusterClientOptions.Builder refreshClusterView(boolean refreshClusterView)
refreshPeriod
/refreshPeriodUnit
. Defaults to false. See
ClusterClientOptions.DEFAULT_REFRESH_CLUSTER_VIEW
.refreshClusterView
- true enable regular cluster topology updates or false to disable
auto-updatingthis
public ClusterClientOptions.Builder refreshPeriod(long refreshPeriod, TimeUnit refreshPeriodUnit)
ClusterClientOptions.DEFAULT_REFRESH_PERIOD
and
ClusterClientOptions.DEFAULT_REFRESH_PERIOD_UNIT
.refreshPeriod
- period for triggering topology updatesrefreshPeriodUnit
- unit for refreshPeriod
this
public ClusterClientOptions.Builder closeStaleConnections(boolean closeStaleConnections)
ClusterClientOptions.isRefreshClusterView()
is true. See
ClusterClientOptions.DEFAULT_CLOSE_STALE_CONNECTIONS
.closeStaleConnections
- true if stale connections are cleaned up after cluster topology updatesthis
public ClusterClientOptions.Builder validateClusterNodeMembership(boolean validateClusterNodeMembership)
ClusterClientOptions.DEFAULT_VALIDATE_CLUSTER_MEMBERSHIP
.validateClusterNodeMembership
- true if validation is enabled.this
public ClusterClientOptions.Builder pingBeforeActivateConnection(boolean pingBeforeActivateConnection)
ClientOptions.Builder
ClientOptions.DEFAULT_PING_BEFORE_ACTIVATE_CONNECTION
.pingBeforeActivateConnection
in class ClientOptions.Builder
pingBeforeActivateConnection
- true/falsethis
public ClusterClientOptions.Builder autoReconnect(boolean autoReconnect)
ClientOptions.Builder
ClientOptions.DEFAULT_AUTO_RECONNECT
.autoReconnect
in class ClientOptions.Builder
autoReconnect
- true/falsethis
public ClusterClientOptions.Builder suspendReconnectOnProtocolFailure(boolean suspendReconnectOnProtocolFailure)
ClientOptions.Builder
ClientOptions.DEFAULT_SUSPEND_RECONNECT_PROTO_FAIL
.suspendReconnectOnProtocolFailure
in class ClientOptions.Builder
suspendReconnectOnProtocolFailure
- true/falsethis
public ClusterClientOptions.Builder cancelCommandsOnReconnectFailure(boolean cancelCommandsOnReconnectFailure)
ClientOptions.Builder
ClientOptions.DEFAULT_CANCEL_CMD_RECONNECT_FAIL
.cancelCommandsOnReconnectFailure
in class ClientOptions.Builder
cancelCommandsOnReconnectFailure
- true/falsethis
public ClusterClientOptions.Builder requestQueueSize(int requestQueueSize)
ClientOptions.Builder
RedisException
if the queue
size is exceeded. Setting the requestQueueSize
to a lower value will lead earlier to exceptions during
overload or while the connection is in a disconnected state. A higher value means hitting the boundary will take
longer to occur, but more requests will potentially be queued up and more heap space is used. Defaults to
false. See ClientOptions.DEFAULT_REQUEST_QUEUE_SIZE
.requestQueueSize
in class ClientOptions.Builder
requestQueueSize
- the queue size.this
public ClusterClientOptions build()
ClusterClientOptions
build
in class ClientOptions.Builder
ClusterClientOptions
Copyright © 2016. All rights reserved.