Package org.apache.tinkerpop.gremlin.driver.simple

Class AbstractClient

java.lang.Object

org.apache.tinkerpop.gremlin.driver.simple.AbstractClient

All Implemented Interfaces:

Closeable, AutoCloseable, SimpleClient

Direct Known Subclasses:

WebSocketClient

public abstract class AbstractClient
extends Object
implements SimpleClient

Author:

Stephen Mallette (http://stephen.genoprime.com)

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.tinkerpop.gremlin.driver.simple.AbstractClient.CallbackResponseHandler	callbackResponseHandler
protected io.netty.channel.EventLoopGroup	group

Constructor Summary

Constructors

Constructor	Description
AbstractClient(String threadPattern)

Method Summary

Modifier and Type	Method	Description
List<ResponseMessage>	submit(RequestMessage requestMessage)
void	submit(RequestMessage requestMessage, Consumer<ResponseMessage> callback)
CompletableFuture<List<ResponseMessage>>	submitAsync(RequestMessage requestMessage)
abstract void	writeAndFlush(RequestMessage requestMessage)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Methods inherited from interface org.apache.tinkerpop.gremlin.driver.simple.SimpleClient

submit, submit, submitAsync

Field Detail

callbackResponseHandler

protected final org.apache.tinkerpop.gremlin.driver.simple.AbstractClient.CallbackResponseHandler callbackResponseHandler

group

protected final io.netty.channel.EventLoopGroup group

Constructor Detail

AbstractClient

public AbstractClient(String threadPattern)

Method Detail

writeAndFlush

public abstract void writeAndFlush(RequestMessage requestMessage)
                            throws Exception

Throws:

Exception

submit

public void submit(RequestMessage requestMessage,
                   Consumer<ResponseMessage> callback)
            throws Exception

Specified by:

submit in interface SimpleClient

Throws:

Exception

submit

public List<ResponseMessage> submit(RequestMessage requestMessage)
                             throws Exception

Specified by:

submit in interface SimpleClient

Throws:

Exception

submitAsync

public CompletableFuture<List<ResponseMessage>> submitAsync(RequestMessage requestMessage)
                                                     throws Exception

Specified by:

submitAsync in interface SimpleClient

Throws:

Exception