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.SessionedClient
cluster, 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, submitAsync
public RequestMessage buildMessage(RequestMessage.Builder builder)
Client
RequestMessage
. 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 Client
protected org.apache.tinkerpop.gremlin.driver.Connection chooseConnection(RequestMessage msg) throws TimeoutException, ConnectionException
Client
Connection
to write the message to.chooseConnection
in class Client
TimeoutException
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.