com.taosdata.jdbc.ws

Class Transport

java.lang.Object

com.taosdata.jdbc.ws.Transport

All Implemented Interfaces:

AutoCloseable

public class Transport
extends Object
implements AutoCloseable

send message

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_MESSAGE_WAIT_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
Transport(WSFunction function, ConnectionParam param, InFlightRequest inFlightRequest)

Method Summary

Modifier and Type	Method and Description
static void	checkConnection(Transport transport, int connectTimeout)
void	close()
void	disconnectAndReconnect()
boolean	isClosed()
Response	send(Request request)
Response	send(String action, long reqId, long stmtId, long type, byte[] rawData)
void	sendWithoutRep(Request request)
void	setBinaryMessageHandler(Consumer<ByteBuffer> binaryMessageHandler)
void	setTextMessageHandler(Consumer<String> textMessageHandler)
void	setTimeout(long timeout)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MESSAGE_WAIT_TIMEOUT

public static final int DEFAULT_MESSAGE_WAIT_TIMEOUT

See Also:

Constant Field Values

Constructor Detail

Transport

public Transport(WSFunction function,
                 ConnectionParam param,
                 InFlightRequest inFlightRequest)
          throws SQLException

Throws:

SQLException

Method Detail

setTextMessageHandler

public void setTextMessageHandler(Consumer<String> textMessageHandler)

setBinaryMessageHandler

public void setBinaryMessageHandler(Consumer<ByteBuffer> binaryMessageHandler)

setTimeout

public void setTimeout(long timeout)

send

public Response send(Request request)
              throws SQLException

Throws:

SQLException

send

public Response send(String action,
                     long reqId,
                     long stmtId,
                     long type,
                     byte[] rawData)
              throws SQLException

Throws:

SQLException

sendWithoutRep

public void sendWithoutRep(Request request)
                    throws SQLException

Throws:

SQLException

isClosed

public boolean isClosed()

disconnectAndReconnect

public void disconnectAndReconnect()
                            throws SQLException

Throws:

SQLException

close

public void close()

Specified by:

close in interface AutoCloseable

checkConnection

public static void checkConnection(Transport transport,
                                   int connectTimeout)
                            throws SQLException

Throws:

SQLException

shutdown

public void shutdown()