Modifier and Type | Method and Description |
---|---|
Cluster.Builder |
addContactPoint(String address) |
Cluster.Builder |
addContactPoints(String... addresses) |
Cluster |
create() |
Cluster.Builder |
enableSsl(boolean enable) |
Cluster.Builder |
loadBalancingStrategy(LoadBalancingStrategy loadBalancingStrategy) |
Cluster.Builder |
maxConnectionPoolSize(int maxSize) |
Cluster.Builder |
maxContentLength(int maxContentLength)
The maximum size in bytes of any request sent to the server.
|
Cluster.Builder |
maxInProcessPerConnection(int maxInProcessPerConnection) |
Cluster.Builder |
maxSimultaneousRequestsPerConnection(int maxSimultaneousRequestsPerConnection) |
Cluster.Builder |
maxWaitForConnection(int maxWait)
The maximum amount of time to wait for a connection to be borrowed from the connection pool.
|
Cluster.Builder |
minConnectionPoolSize(int minSize) |
Cluster.Builder |
minInProcessPerConnection(int minInProcessPerConnection) |
Cluster.Builder |
minSimultaneousRequestsPerConnection(int minSimultaneousRequestsPerConnection) |
Cluster.Builder |
nioPoolSize(int nioPoolSize)
Size of the pool for handling request/response operations.
|
Cluster.Builder |
port(int port) |
Cluster.Builder |
reconnectInterval(int interval)
Time in milliseconds to wait between retries when attempting to reconnect to a dead host.
|
Cluster.Builder |
reconnectIntialDelay(int initialDelay)
Time in milliseconds to wait before attempting to reconnect to a dead host after it has been marked dead.
|
Cluster.Builder |
resultIterationBatchSize(int size)
Override the server setting that determines how many results are returned per batch.
|
Cluster.Builder |
serializer(MessageSerializer serializer) |
Cluster.Builder |
serializer(Serializers mimeType) |
Cluster.Builder |
serializer(String mimeType) |
Cluster.Builder |
workerPoolSize(int workerPoolSize)
Size of the pool for handling background work.
|
public Cluster.Builder nioPoolSize(int nioPoolSize)
public Cluster.Builder workerPoolSize(int workerPoolSize)
public Cluster.Builder serializer(String mimeType)
public Cluster.Builder serializer(Serializers mimeType)
public Cluster.Builder serializer(MessageSerializer serializer)
public Cluster.Builder enableSsl(boolean enable)
public Cluster.Builder minInProcessPerConnection(int minInProcessPerConnection)
public Cluster.Builder maxInProcessPerConnection(int maxInProcessPerConnection)
public Cluster.Builder maxSimultaneousRequestsPerConnection(int maxSimultaneousRequestsPerConnection)
public Cluster.Builder minSimultaneousRequestsPerConnection(int minSimultaneousRequestsPerConnection)
public Cluster.Builder maxConnectionPoolSize(int maxSize)
public Cluster.Builder minConnectionPoolSize(int minSize)
public Cluster.Builder resultIterationBatchSize(int size)
public Cluster.Builder maxWaitForConnection(int maxWait)
public Cluster.Builder maxContentLength(int maxContentLength)
public Cluster.Builder reconnectIntialDelay(int initialDelay)
public Cluster.Builder reconnectInterval(int interval)
public Cluster.Builder loadBalancingStrategy(LoadBalancingStrategy loadBalancingStrategy)
public Cluster.Builder addContactPoint(String address)
public Cluster.Builder addContactPoints(String... addresses)
public Cluster.Builder port(int port)
public Cluster create()
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.