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(org.apache.tinkerpop.gremlin.driver.message.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(org.apache.tinkerpop.gremlin.driver.message.RequestMessage msg) throws TimeoutException, org.apache.tinkerpop.gremlin.driver.exception.ConnectionException
LoadBalancingStrategy
to choose the best Host
and then selects the best connection
from that host's connection pool.chooseConnection
in class Client
TimeoutException
org.apache.tinkerpop.gremlin.driver.exception.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.