public static class Client.ClusteredClient extends Client
Client
implementation that does not operate in a session. Requests are sent to multiple servers
given a LoadBalancingStrategy
. Transactions are automatically committed
(or rolled-back on error) after each request.Client.ClusteredClient, Client.SessionedClient
cluster, initialized
Modifier and Type | Method and Description |
---|---|
protected org.apache.tinkerpop.gremlin.driver.Connection |
chooseConnection(RequestMessage msg)
Uses a
LoadBalancingStrategy to choose the best Host and then selects the best connection
from that host's connection pool. |
CompletableFuture<Void> |
closeAsync()
Closes all the connection pools on all hosts.
|
protected void |
initializeImplementation()
Initializes the connection pools on all hosts.
|
buildMessage, close, init, submit, submit, submitAsync, submitAsync, submitAsync
protected org.apache.tinkerpop.gremlin.driver.Connection chooseConnection(RequestMessage msg) throws TimeoutException, ConnectionException
LoadBalancingStrategy
to choose the best Host
and then selects the best connection
from that host's connection pool.chooseConnection
in class Client
TimeoutException
ConnectionException
protected void initializeImplementation()
initializeImplementation
in class Client
public CompletableFuture<Void> closeAsync()
closeAsync
in class Client
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.