public static class Client.SessionedClient extends Client
Client implementation that operates in the context of a session. Requests are sent to a single
server, where each request is bound to the same thread with the same set of bindings across requests.
Transaction are not automatically committed. It is up the client to issue commit/rollback commands.Client.ClusteredClient, Client.SessionedClientcluster, initialized| Modifier and Type | Method and Description |
|---|---|
RequestMessage |
buildMessage(RequestMessage.Builder builder)
Makes any final changes to the builder and returns the constructed
RequestMessage. |
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. |
close, init, submit, submit, submitAsync, submitAsync, submitAsyncpublic RequestMessage buildMessage(RequestMessage.Builder builder)
ClientRequestMessage. Implementers
may choose to override this message to append data to the request before sending. By default, this method
will simply call the RequestMessage.Builder.create() and return
the RequestMessage.buildMessage in class Clientprotected org.apache.tinkerpop.gremlin.driver.Connection chooseConnection(RequestMessage msg) throws TimeoutException, ConnectionException
ClientConnection to write the message to.chooseConnection in class ClientTimeoutExceptionConnectionExceptionprotected void initializeImplementation()
ClientClient.init() method.initializeImplementation in class Clientpublic CompletableFuture<Void> closeAsync()
ClientClient.closeAsync in class ClientCopyright © 2013–2015 Apache Software Foundation. All rights reserved.