org.apache.tinkerpop.gremlin.driver

Class Client.ClusteredClient

java.lang.Object

org.apache.tinkerpop.gremlin.driver.Client

org.apache.tinkerpop.gremlin.driver.Client.ClusteredClient

Enclosing class:

Client

public static class Client.ClusteredClient
extends Client

A 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.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.tinkerpop.gremlin.driver.Client

Client.ClusteredClient, Client.SessionedClient

Field Summary

Fields inherited from class org.apache.tinkerpop.gremlin.driver.Client

cluster, initialized

Method Summary

Modifier and Type	Method and Description
protected org.apache.tinkerpop.gremlin.driver.Connection	chooseConnection(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.

Methods inherited from class org.apache.tinkerpop.gremlin.driver.Client

buildMessage, close, init, submit, submit, submitAsync, submitAsync, submitAsync

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

chooseConnection

protected org.apache.tinkerpop.gremlin.driver.Connection chooseConnection(RequestMessage msg)
                                                                   throws TimeoutException,
                                                                          ConnectionException

Description copied from class: Client

Chooses a Connection to write the message to.

Specified by:

chooseConnection in class Client

Throws:

TimeoutException

ConnectionException

initializeImplementation

protected void initializeImplementation()

Description copied from class: Client

Called in the Client.init() method.

Specified by:

initializeImplementation in class Client

closeAsync

public CompletableFuture<Void> closeAsync()

Description copied from class: Client

Asynchronous close of the Client.

Specified by:

closeAsync in class Client