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)
Chooses a
Connection to write the message to. |
CompletableFuture<Void> |
closeAsync()
Asynchronous close of the
Client . |
protected void |
initializeImplementation()
Called in the
Client.init() method. |
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
Client
Connection
to write the message to.chooseConnection
in class Client
TimeoutException
org.apache.tinkerpop.gremlin.driver.exception.ConnectionException
protected void initializeImplementation()
Client
Client.init()
method.initializeImplementation
in class Client
public CompletableFuture<Void> closeAsync()
Client
Client
.closeAsync
in class Client
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.