Package com.arangodb.vst.internal

Class VstConnection<T>

java.lang.Object

com.arangodb.vst.internal.VstConnection<T>

All Implemented Interfaces:

Connection, Closeable, AutoCloseable

Direct Known Subclasses:

VstConnectionAsync

public abstract class VstConnection<T>
extends Object
implements Connection

Author:

Mark Vollmary

Field Summary

Fields

Modifier and Type	Field	Description
protected final MessageStore	messageStore
protected final Integer	timeout

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	VstConnection(ArangoConfig config, HostDescription host)

Method Summary

Modifier and Type	Method	Description
void	close()
protected abstract void	doKeepAlive()
boolean	isOpen()
void	open()
protected void	readBytesIntoBuffer(byte[] buf, int off, int len)
protected Chunk	readChunk()
protected T	sendKeepAlive()
void	setJwt(String jwt)
abstract T	write(Message message, Collection<Chunk> chunks)
protected void	writeIntern(Message message, Collection<Chunk> chunks)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.arangodb.internal.net.Connection

executeAsync

Field Details

messageStore

protected final MessageStore messageStore

timeout

protected final Integer timeout

Constructor Details

VstConnection

protected VstConnection(ArangoConfig config,
 HostDescription host)

Method Details

sendKeepAlive

protected T sendKeepAlive()

write

public abstract T write(Message message,
 Collection<Chunk> chunks)

doKeepAlive

protected abstract void doKeepAlive()

isOpen

public boolean isOpen()

open

public void open()
          throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

writeIntern

protected void writeIntern(Message message,
 Collection<Chunk> chunks)

readChunk

protected Chunk readChunk()
                   throws IOException

Throws:

IOException

readBytesIntoBuffer

protected void readBytesIntoBuffer(byte[] buf,
 int off,
 int len)
                            throws IOException

Throws:

IOException

setJwt

public void setJwt(String jwt)

Specified by:

setJwt in interface Connection