Package deltix.qsrv.hf.tickdb.comm

Class TDBProtocol

java.lang.Object

deltix.qsrv.hf.pub.util.SerializationUtils

deltix.qsrv.hf.tickdb.comm.TDBProtocol

public abstract class TDBProtocol
extends SerializationUtils

Field Summary

Fields

Modifier and Type	Field	Description
static java.lang.String	AERON_CHANNEL
static int	AERON_SUPPORT_VERSION
static int	AF_STUB_STREAM
static boolean	ALLOW_AERON_FOR_CURSOR
static boolean	ALLOW_AERON_FOR_LOADER
static int	CURREQ_ADD_ENTITIES
static int	CURREQ_ADD_ENTITIES_TYPES
static int	CURREQ_ADD_STREAMS
static int	CURREQ_ADD_TYPES
static int	CURREQ_ALL_ENTITIES
static int	CURREQ_ALL_TYPES
static int	CURREQ_CLEAR_ENTITIES
static int	CURREQ_CLEAR_TYPES
static int	CURREQ_DISCONNECT
static int	CURREQ_GET_MULTICAST_CURSOR_METADATA
static int	CURREQ_REMOVE_ALL_STREAMS
static int	CURREQ_REMOVE_ENTITIES
static int	CURREQ_REMOVE_ENTITIES_TYPES
static int	CURREQ_REMOVE_STREAMS
static int	CURREQ_REMOVE_TYPES
static int	CURREQ_RESET_INSTRUMENTS
static int	CURREQ_RESET_TIME
static int	CURREQ_SET_TYPES
static int	CURRESP_ACK_SERIAL
static int	CURRESP_END_OF_CURSOR
static int	CURRESP_ERROR
static int	CURRESP_LOAD_ENTITY
static int	CURRESP_LOAD_STREAM
static int	CURRESP_LOAD_TYPE
static int	CURRESP_MSG
static int	CURRESP_MSG_MULTIPART_BODY
static int	CURRESP_MSG_MULTIPART_HEAD
static int	DEFAULT_PORT
static int	DEFAULT_SSL_PORT
static java.lang.String	DEFAULT_URL
static int	INCOMPATIBLE_CLIENT_PROTOCOL_VERSION
static int	LOAD_CLOSE
static int	LOAD_FLUSH
static int	LOAD_MSG
static int	LOAD_MULTIPART_BODY
static int	LOAD_MULTIPART_HEAD
static int	LOAD_MULTIPART_HEAD_REMOVE
static int	LOAD_REMOVE
static int	LOADRESP_CLOSE_OK
static int	LOADRESP_ENTITIES_CHANGE
static int	LOADRESP_ERROR
static int	LOADRESP_FILTER_CHANGE
static int	LOADRESP_FLUSH_OK
static int	LOADRESP_TYPES_CHANGE
static int	MIN_CLIENT_VERSION	Server will refuse to talk to a client unless the client's version is at least this number.
static int	MIN_SERVER_VERSION	Client will refuse to talk to a server unless the server's version is at least this number.
static boolean	NEEDS_AERON_DRIVER
static int	NO_CHANGES
static java.lang.String	PROTOCOL_ID
static java.lang.String	PROTOCOL_PREFIX
static int	READ_ONLY
static int	READ_WRITE
static int	REQ_ABORT_BG_PROCESS
static int	REQ_CLEAR_DATA
static int	REQ_CLOSE_SESSION
static int	REQ_COMPILE_QQL
static int	REQ_CONNECT
static int	REQ_CREATE_CURSOR
static int	REQ_CREATE_CUSTOM_TOPIC
static int	REQ_CREATE_FILE_STREAM
static int	REQ_CREATE_MULTICAST_CURSOR
static int	REQ_CREATE_MULTICAST_TOPIC
static int	REQ_CREATE_STREAM
static int	REQ_CREATE_TOPIC
static int	REQ_CREATE_TOPIC_PUBLISHER
static int	REQ_CREATE_TOPIC_SUBSCRIBER
static int	REQ_CREATE_TOPIC_SUBSCRIBER_NO_MAPPING
static int	REQ_DELETE_RANGE
static int	REQ_DELETE_SPACES
static int	REQ_DELETE_STREAM
static int	REQ_DELETE_TOPIC
static int	REQ_DESCRIBE
static int	REQ_DESCRIBE_QUERY
static int	REQ_ENABLE_VERSIONING
static int	REQ_GET_BG_PROCESS
static int	REQ_GET_DATA_VERSION
static int	REQ_GET_INSTR_COMPOSITION
static int	REQ_GET_LOCK_STATE
static int	REQ_GET_MD_VERSION
static int	REQ_GET_METADATA
static int	REQ_GET_REPLICA_VERSION
static int	REQ_GET_SERVER_TIME
static int	REQ_GET_SIZE
static int	REQ_GET_STREAM
static int	REQ_GET_STREAM_DESCR
static int	REQ_GET_STREAM_HA
static int	REQ_GET_STREAM_NAME
static int	REQ_GET_STREAM_OPTIONS
static int	REQ_GET_STREAM_PERIOD
static int	REQ_GET_STREAM_PROPERTY
static int	REQ_GET_STREAM_TNF
static int	REQ_GET_STREAM_TYPE
static int	REQ_GET_STREAM_TYPE_VERSION
static int	REQ_GET_STREAMS
static int	REQ_GET_TIME_RANGE
static int	REQ_GET_TIME_RANGE_FOR_SPACE
static int	REQ_GET_TOPIC_INSTRUMENT_MAPPING
static int	REQ_GET_TOPIC_METADATA
static int	REQ_GET_TOPIC_TEMPORARY_INSTRUMENT_MAPPING
static int	REQ_LIST_ENTITIES
static int	REQ_LIST_IDS_FOR_SPACE
static int	REQ_LIST_STREAM_SPACES
static int	REQ_LIST_STREAMS
static int	REQ_LIST_SYMBOLS_FOR_SPACE
static int	REQ_LIST_TIME_RANGE
static int	REQ_LIST_TOPICS
static int	REQ_LOCK_STREAM
static int	REQ_OPEN_LOADER
static int	REQ_PURGE_STREAM
static int	REQ_PURGE_STREAM_SPACE
static int	REQ_RENAME_INSTRUMENTS
static int	REQ_RENAME_SPACES
static int	REQ_RENAME_STREAM
static int	REQ_RUN_TASK
static int	REQ_SET_METADATA
static int	REQ_SET_REPLICA_VERSION
static int	REQ_SET_STREAM_DESCR
static int	REQ_SET_STREAM_HA
static int	REQ_SET_STREAM_NAME
static int	REQ_SET_STREAM_OWNER
static int	REQ_SET_STREAM_PERIOD
static int	REQ_SET_STREAM_TYPE
static int	REQ_START_SESSION
static int	REQ_TRIM_TO_SIZE
static int	REQ_TRUNCATE_DATA
static int	REQ_TRY_LOCK_STREAM
static int	REQ_UNLOCK_STREAM
static int	RESP_ERROR
static int	RESP_EXCEPTION
static int	RESP_LICENSE_ERROR
static int	RESP_OK
static boolean	SEND_SEQUENCE
static int	SESSION_CLOSED
static int	SESSION_STARTED
static java.lang.String	SSL_DEFAULT_URL
static java.lang.String	SSL_PROTOCOL_ID
static java.lang.String	SSL_PROTOCOL_PREFIX
static int	STREAM_CREATED
static int	STREAM_DELETED
static int	STREAM_PROPERTY
static int	STREAM_PROPERTY_CHANGED
static int	STREAM_RENAMED
static int	STREAMS_CHANGED
static int	STREAMS_DEFINITION
static byte	TRANSPORT_TYPE_AERON
static byte	TRANSPORT_TYPE_SOCKET
static boolean	USE_MAGIC
static boolean	USE_TIME_CODEC_FOR_AERON
static int	VERSION	This component's version, whether server or client.

Constructor Summary

Constructors

Constructor	Description
TDBProtocol()

Method Summary

Modifier and Type	Method	Description
static java.lang.String	getHttpProtocol(boolean ssl)
static int	getPort(int port, boolean ssl)
static java.lang.String	getProtocol(boolean ssl)
static int	getSSLPort(int port)
static boolean	isSSL(java.lang.String protocol)
static BackgroundProcessInfo	readBGProcessInfo(java.io.DataInputStream in)
static java.lang.Throwable	readBinary(java.io.DataInputStream in)
static ClassSet	readClassSet(java.io.DataInputStream in)
static ClassSet	readClassSet(java.lang.String in)
static UserCredentials	readCredentials(VSChannel channel)
static java.lang.Throwable	readError(java.io.DataInputStream in)
static java.lang.Throwable	readError(java.io.DataInputStream in, ExceptionResolver resolver)
static java.lang.String[]	readNonNullableStrings(java.io.DataInputStream in)
static java.lang.String[]	readNullableStringArray(java.io.DataInputStream din)
static Parameter[]	readParameters(java.io.DataInputStream in, int clientVersion)
static StreamOptions	readStreamOptions(java.io.DataInputStream in, int clientVersion)
static StreamOptions	readStreamOptions76(java.io.DataInputStream in)
static long[]	readTimeRangeLong(java.io.DataInputStream in)
static TransformationTask	readTransformationTask(java.io.DataInputStream in)
static java.lang.String	toString(RecordClassSet md)
static void	writeBGProcessInfo(BackgroundProcessInfo info, java.io.DataOutputStream out)
static void	writeBinary(java.io.DataOutputStream out, java.lang.Throwable e)
static void	writeClassSet(java.io.DataOutputStream out, ClassSet set)
static void	writeCredentials(VSChannel channel, UserPrincipal principal)
static void	writeCredentials(VSChannel channel, UserPrincipal principal, java.security.Principal delegate)
static void	writeError(java.io.DataOutputStream out, java.lang.Throwable e)
static void	writeNonNullableStrings(java.io.DataOutputStream out, java.lang.String[] strings)
static void	writeNullableStringArray(java.io.DataOutputStream out, java.lang.String[] strings)
static void	writeNullableStringArray(java.io.DataOutputStream out, java.util.List<java.lang.CharSequence> strings)
static void	writeParameters(Parameter[] params, java.io.DataOutputStream out)
static void	writeStream(java.io.DataOutputStream out, DXTickStream stream, int clientVersion)
static void	writeStreamOptions(java.io.DataOutputStream out, StreamOptions so, int clientVersion)
static void	writeTimeRange(long[] range, java.io.DataOutputStream out)
static void	writeTimeRange(deltix.qsrv.hf.pub.TimeInterval range, java.io.DataOutputStream out)
static void	writeTimeRange(java.io.DataOutputStream out, DXTickStream stream, deltix.qsrv.hf.pub.InstrumentIdentity[] ids)
static void	writeTransformationTask(TransformationTask task, java.io.DataOutputStream out)

Methods inherited from class deltix.qsrv.hf.pub.util.SerializationUtils

readHugeString, readInstrumentIdentities, readInstrumentIdentity, readInstrumentType, readInstrumentTypes, readNullableBoolean, readNullableInt, readNullableString, readUTFString, writeHugeString, writeInstrumentIdentities, writeInstrumentIdentities, writeInstrumentIdentities, writeInstrumentIdentity, writeInstrumentType, writeInstrumentTypes, writeNullableBoolean, writeNullableInt, writeNullableString, writeSymbols, writeSymbols, writeSymbols, writeUTFString

Methods inherited from class java.lang.Object

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

Field Detail

USE_MAGIC

public static final boolean USE_MAGIC

See Also:

Constant Field Values

SEND_SEQUENCE

public static final boolean SEND_SEQUENCE

See Also:

Constant Field Values

ALLOW_AERON_FOR_CURSOR

public static final boolean ALLOW_AERON_FOR_CURSOR

See Also:

Constant Field Values

ALLOW_AERON_FOR_LOADER

public static final boolean ALLOW_AERON_FOR_LOADER

See Also:

Constant Field Values

NEEDS_AERON_DRIVER

public static final boolean NEEDS_AERON_DRIVER

See Also:

Constant Field Values

USE_TIME_CODEC_FOR_AERON

public static final boolean USE_TIME_CODEC_FOR_AERON

See Also:

Constant Field Values

AERON_CHANNEL

public static final java.lang.String AERON_CHANNEL

See Also:

Constant Field Values

PROTOCOL_ID

public static final java.lang.String PROTOCOL_ID

See Also:

Constant Field Values

SSL_PROTOCOL_ID

public static final java.lang.String SSL_PROTOCOL_ID

See Also:

Constant Field Values

PROTOCOL_PREFIX

public static final java.lang.String PROTOCOL_PREFIX

See Also:

Constant Field Values

SSL_PROTOCOL_PREFIX

public static final java.lang.String SSL_PROTOCOL_PREFIX

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

Constant Field Values

DEFAULT_SSL_PORT

public static final int DEFAULT_SSL_PORT

DEFAULT_URL

public static final java.lang.String DEFAULT_URL

See Also:

Constant Field Values

SSL_DEFAULT_URL

public static final java.lang.String SSL_DEFAULT_URL

See Also:

Constant Field Values

VERSION

public static final int VERSION

This component's version, whether server or client.

See Also:

Constant Field Values

MIN_CLIENT_VERSION

public static final int MIN_CLIENT_VERSION

Server will refuse to talk to a client unless the client's version is at least this number.

See Also:

Constant Field Values

MIN_SERVER_VERSION

public static final int MIN_SERVER_VERSION

Client will refuse to talk to a server unless the server's version is at least this number.

See Also:

Constant Field Values

AERON_SUPPORT_VERSION

public static final int AERON_SUPPORT_VERSION

See Also:

Constant Field Values

NO_CHANGES

public static final int NO_CHANGES

See Also:

Constant Field Values

READ_ONLY

public static final int READ_ONLY

See Also:

Constant Field Values

READ_WRITE

public static final int READ_WRITE

See Also:

Constant Field Values

INCOMPATIBLE_CLIENT_PROTOCOL_VERSION

public static final int INCOMPATIBLE_CLIENT_PROTOCOL_VERSION

See Also:

Constant Field Values

REQ_CONNECT

public static final int REQ_CONNECT

See Also:

Constant Field Values

REQ_LIST_STREAMS

public static final int REQ_LIST_STREAMS

See Also:

Constant Field Values

REQ_GET_MD_VERSION

public static final int REQ_GET_MD_VERSION

See Also:

Constant Field Values

REQ_GET_METADATA

public static final int REQ_GET_METADATA

See Also:

Constant Field Values

REQ_SET_METADATA

public static final int REQ_SET_METADATA

See Also:

Constant Field Values

REQ_TRIM_TO_SIZE

public static final int REQ_TRIM_TO_SIZE

See Also:

Constant Field Values

REQ_GET_STREAM

public static final int REQ_GET_STREAM

See Also:

Constant Field Values

REQ_GET_STREAM_NAME

public static final int REQ_GET_STREAM_NAME

See Also:

Constant Field Values

REQ_GET_STREAM_DESCR

public static final int REQ_GET_STREAM_DESCR

See Also:

Constant Field Values

REQ_GET_STREAM_TNF

public static final int REQ_GET_STREAM_TNF

See Also:

Constant Field Values

REQ_GET_TIME_RANGE

public static final int REQ_GET_TIME_RANGE

See Also:

Constant Field Values

REQ_LIST_ENTITIES

public static final int REQ_LIST_ENTITIES

See Also:

Constant Field Values

REQ_SET_STREAM_TYPE

public static final int REQ_SET_STREAM_TYPE

See Also:

Constant Field Values

REQ_GET_SIZE

public static final int REQ_GET_SIZE

See Also:

Constant Field Values

REQ_GET_STREAM_TYPE

public static final int REQ_GET_STREAM_TYPE

See Also:

Constant Field Values

REQ_GET_STREAM_TYPE_VERSION

public static final int REQ_GET_STREAM_TYPE_VERSION

See Also:

Constant Field Values

REQ_LIST_TIME_RANGE

public static final int REQ_LIST_TIME_RANGE

See Also:

Constant Field Values

REQ_PURGE_STREAM

public static final int REQ_PURGE_STREAM

See Also:

Constant Field Values

REQ_GET_BG_PROCESS

public static final int REQ_GET_BG_PROCESS

See Also:

Constant Field Values

REQ_ABORT_BG_PROCESS

public static final int REQ_ABORT_BG_PROCESS

See Also:

Constant Field Values

REQ_CLEAR_DATA

public static final int REQ_CLEAR_DATA

See Also:

Constant Field Values

REQ_SET_STREAM_NAME

public static final int REQ_SET_STREAM_NAME

See Also:

Constant Field Values

REQ_SET_STREAM_DESCR

public static final int REQ_SET_STREAM_DESCR

See Also:

Constant Field Values

REQ_GET_STREAM_PERIOD

public static final int REQ_GET_STREAM_PERIOD

See Also:

Constant Field Values

REQ_SET_STREAM_PERIOD

public static final int REQ_SET_STREAM_PERIOD

See Also:

Constant Field Values

REQ_TRUNCATE_DATA

public static final int REQ_TRUNCATE_DATA

See Also:

Constant Field Values

REQ_GET_SERVER_TIME

public static final int REQ_GET_SERVER_TIME

See Also:

Constant Field Values

REQ_GET_STREAM_OPTIONS

public static final int REQ_GET_STREAM_OPTIONS

See Also:

Constant Field Values

REQ_LOCK_STREAM

public static final int REQ_LOCK_STREAM

See Also:

Constant Field Values

REQ_TRY_LOCK_STREAM

public static final int REQ_TRY_LOCK_STREAM

See Also:

Constant Field Values

REQ_UNLOCK_STREAM

public static final int REQ_UNLOCK_STREAM

See Also:

Constant Field Values

REQ_GET_LOCK_STATE

public static final int REQ_GET_LOCK_STATE

See Also:

Constant Field Values

REQ_GET_STREAM_HA

public static final int REQ_GET_STREAM_HA

See Also:

Constant Field Values

REQ_SET_STREAM_HA

public static final int REQ_SET_STREAM_HA

See Also:

Constant Field Values

REQ_ENABLE_VERSIONING

public static final int REQ_ENABLE_VERSIONING

See Also:

Constant Field Values

REQ_GET_DATA_VERSION

public static final int REQ_GET_DATA_VERSION

See Also:

Constant Field Values

REQ_GET_REPLICA_VERSION

public static final int REQ_GET_REPLICA_VERSION

See Also:

Constant Field Values

REQ_SET_REPLICA_VERSION

public static final int REQ_SET_REPLICA_VERSION

See Also:

Constant Field Values

REQ_GET_INSTR_COMPOSITION

public static final int REQ_GET_INSTR_COMPOSITION

See Also:

Constant Field Values

REQ_SET_STREAM_OWNER

public static final int REQ_SET_STREAM_OWNER

See Also:

Constant Field Values

REQ_DELETE_RANGE

public static final int REQ_DELETE_RANGE

See Also:

Constant Field Values

REQ_RENAME_INSTRUMENTS

public static final int REQ_RENAME_INSTRUMENTS

See Also:

Constant Field Values

REQ_COMPILE_QQL

public static final int REQ_COMPILE_QQL

See Also:

Constant Field Values

REQ_DESCRIBE

public static final int REQ_DESCRIBE

See Also:

Constant Field Values

REQ_LIST_STREAM_SPACES

public static final int REQ_LIST_STREAM_SPACES

See Also:

Constant Field Values

REQ_LIST_SYMBOLS_FOR_SPACE

public static final int REQ_LIST_SYMBOLS_FOR_SPACE

See Also:

Constant Field Values

REQ_GET_TIME_RANGE_FOR_SPACE

public static final int REQ_GET_TIME_RANGE_FOR_SPACE

See Also:

Constant Field Values

REQ_PURGE_STREAM_SPACE

public static final int REQ_PURGE_STREAM_SPACE

See Also:

Constant Field Values

REQ_LIST_IDS_FOR_SPACE

public static final int REQ_LIST_IDS_FOR_SPACE

See Also:

Constant Field Values

REQ_DELETE_SPACES

public static final int REQ_DELETE_SPACES

See Also:

Constant Field Values

REQ_RENAME_SPACES

public static final int REQ_RENAME_SPACES

See Also:

Constant Field Values

REQ_DESCRIBE_QUERY

public static final int REQ_DESCRIBE_QUERY

See Also:

Constant Field Values

REQ_CREATE_STREAM

public static final int REQ_CREATE_STREAM

See Also:

Constant Field Values

REQ_DELETE_STREAM

public static final int REQ_DELETE_STREAM

See Also:

Constant Field Values

REQ_RENAME_STREAM

public static final int REQ_RENAME_STREAM

See Also:

Constant Field Values

REQ_RUN_TASK

public static final int REQ_RUN_TASK

See Also:

Constant Field Values

REQ_CREATE_FILE_STREAM

public static final int REQ_CREATE_FILE_STREAM

See Also:

Constant Field Values

REQ_CREATE_TOPIC

public static final int REQ_CREATE_TOPIC

See Also:

Constant Field Values

REQ_DELETE_TOPIC

public static final int REQ_DELETE_TOPIC

See Also:

Constant Field Values

REQ_CREATE_TOPIC_PUBLISHER

public static final int REQ_CREATE_TOPIC_PUBLISHER

See Also:

Constant Field Values

REQ_CREATE_TOPIC_SUBSCRIBER

public static final int REQ_CREATE_TOPIC_SUBSCRIBER

See Also:

Constant Field Values

REQ_LIST_TOPICS

public static final int REQ_LIST_TOPICS

See Also:

Constant Field Values

REQ_GET_TOPIC_METADATA

public static final int REQ_GET_TOPIC_METADATA

See Also:

Constant Field Values

REQ_CREATE_MULTICAST_TOPIC

public static final int REQ_CREATE_MULTICAST_TOPIC

See Also:

Constant Field Values

REQ_CREATE_CUSTOM_TOPIC

public static final int REQ_CREATE_CUSTOM_TOPIC

See Also:

Constant Field Values

REQ_GET_TOPIC_INSTRUMENT_MAPPING

public static final int REQ_GET_TOPIC_INSTRUMENT_MAPPING

See Also:

Constant Field Values

REQ_CREATE_TOPIC_SUBSCRIBER_NO_MAPPING

public static final int REQ_CREATE_TOPIC_SUBSCRIBER_NO_MAPPING

See Also:

Constant Field Values

REQ_GET_TOPIC_TEMPORARY_INSTRUMENT_MAPPING

public static final int REQ_GET_TOPIC_TEMPORARY_INSTRUMENT_MAPPING

See Also:

Constant Field Values

REQ_CREATE_CURSOR

public static final int REQ_CREATE_CURSOR

See Also:

Constant Field Values

REQ_CREATE_MULTICAST_CURSOR

public static final int REQ_CREATE_MULTICAST_CURSOR

See Also:

Constant Field Values

CURREQ_DISCONNECT

public static final int CURREQ_DISCONNECT

See Also:

Constant Field Values

CURREQ_ADD_STREAMS

public static final int CURREQ_ADD_STREAMS

See Also:

Constant Field Values

CURREQ_REMOVE_STREAMS

public static final int CURREQ_REMOVE_STREAMS

See Also:

Constant Field Values

CURREQ_REMOVE_ALL_STREAMS

public static final int CURREQ_REMOVE_ALL_STREAMS

See Also:

Constant Field Values

CURREQ_ALL_ENTITIES

public static final int CURREQ_ALL_ENTITIES

See Also:

Constant Field Values

CURREQ_ADD_ENTITIES

public static final int CURREQ_ADD_ENTITIES

See Also:

Constant Field Values

CURREQ_REMOVE_ENTITIES

public static final int CURREQ_REMOVE_ENTITIES

See Also:

Constant Field Values

CURREQ_CLEAR_ENTITIES

public static final int CURREQ_CLEAR_ENTITIES

See Also:

Constant Field Values

CURREQ_ALL_TYPES

public static final int CURREQ_ALL_TYPES

See Also:

Constant Field Values

CURREQ_ADD_TYPES

public static final int CURREQ_ADD_TYPES

See Also:

Constant Field Values

CURREQ_REMOVE_TYPES

public static final int CURREQ_REMOVE_TYPES

See Also:

Constant Field Values

CURREQ_CLEAR_TYPES

public static final int CURREQ_CLEAR_TYPES

See Also:

Constant Field Values

CURREQ_SET_TYPES

public static final int CURREQ_SET_TYPES

See Also:

Constant Field Values

CURREQ_RESET_TIME

public static final int CURREQ_RESET_TIME

See Also:

Constant Field Values

CURREQ_RESET_INSTRUMENTS

public static final int CURREQ_RESET_INSTRUMENTS

See Also:

Constant Field Values

CURREQ_ADD_ENTITIES_TYPES

public static final int CURREQ_ADD_ENTITIES_TYPES

See Also:

Constant Field Values

CURREQ_REMOVE_ENTITIES_TYPES

public static final int CURREQ_REMOVE_ENTITIES_TYPES

See Also:

Constant Field Values

CURREQ_GET_MULTICAST_CURSOR_METADATA

public static final int CURREQ_GET_MULTICAST_CURSOR_METADATA

See Also:

Constant Field Values

CURRESP_END_OF_CURSOR

public static final int CURRESP_END_OF_CURSOR

See Also:

Constant Field Values

CURRESP_ACK_SERIAL

public static final int CURRESP_ACK_SERIAL

See Also:

Constant Field Values

CURRESP_ERROR

public static final int CURRESP_ERROR

See Also:

Constant Field Values

CURRESP_LOAD_TYPE

public static final int CURRESP_LOAD_TYPE

See Also:

Constant Field Values

CURRESP_LOAD_ENTITY

public static final int CURRESP_LOAD_ENTITY

See Also:

Constant Field Values

CURRESP_LOAD_STREAM

public static final int CURRESP_LOAD_STREAM

See Also:

Constant Field Values

CURRESP_MSG

public static final int CURRESP_MSG

See Also:

Constant Field Values

CURRESP_MSG_MULTIPART_HEAD

public static final int CURRESP_MSG_MULTIPART_HEAD

See Also:

Constant Field Values

CURRESP_MSG_MULTIPART_BODY

public static final int CURRESP_MSG_MULTIPART_BODY

See Also:

Constant Field Values

REQ_OPEN_LOADER

public static final int REQ_OPEN_LOADER

See Also:

Constant Field Values

LOAD_CLOSE

public static final int LOAD_CLOSE

See Also:

Constant Field Values

LOAD_REMOVE

public static final int LOAD_REMOVE

See Also:

Constant Field Values

LOAD_FLUSH

public static final int LOAD_FLUSH

See Also:

Constant Field Values

LOAD_MSG

public static final int LOAD_MSG

See Also:

Constant Field Values

LOAD_MULTIPART_HEAD

public static final int LOAD_MULTIPART_HEAD

See Also:

Constant Field Values

LOAD_MULTIPART_HEAD_REMOVE

public static final int LOAD_MULTIPART_HEAD_REMOVE

See Also:

Constant Field Values

LOAD_MULTIPART_BODY

public static final int LOAD_MULTIPART_BODY

See Also:

Constant Field Values

LOADRESP_ERROR

public static final int LOADRESP_ERROR

See Also:

Constant Field Values

LOADRESP_FILTER_CHANGE

public static final int LOADRESP_FILTER_CHANGE

See Also:

Constant Field Values

LOADRESP_ENTITIES_CHANGE

public static final int LOADRESP_ENTITIES_CHANGE

See Also:

Constant Field Values

LOADRESP_TYPES_CHANGE

public static final int LOADRESP_TYPES_CHANGE

See Also:

Constant Field Values

LOADRESP_CLOSE_OK

public static final int LOADRESP_CLOSE_OK

See Also:

Constant Field Values

LOADRESP_FLUSH_OK

public static final int LOADRESP_FLUSH_OK

See Also:

Constant Field Values

RESP_OK

public static final int RESP_OK

See Also:

Constant Field Values

RESP_ERROR

public static final int RESP_ERROR

See Also:

Constant Field Values

RESP_LICENSE_ERROR

public static final int RESP_LICENSE_ERROR

See Also:

Constant Field Values

RESP_EXCEPTION

public static final int RESP_EXCEPTION

See Also:

Constant Field Values

REQ_START_SESSION

public static final int REQ_START_SESSION

See Also:

Constant Field Values

REQ_GET_STREAMS

public static final int REQ_GET_STREAMS

See Also:

Constant Field Values

REQ_GET_STREAM_PROPERTY

public static final int REQ_GET_STREAM_PROPERTY

See Also:

Constant Field Values

REQ_CLOSE_SESSION

public static final int REQ_CLOSE_SESSION

See Also:

Constant Field Values

STREAM_PROPERTY_CHANGED

public static final int STREAM_PROPERTY_CHANGED

See Also:

Constant Field Values

STREAM_DELETED

public static final int STREAM_DELETED

See Also:

Constant Field Values

STREAM_CREATED

public static final int STREAM_CREATED

See Also:

Constant Field Values

STREAM_RENAMED

public static final int STREAM_RENAMED

See Also:

Constant Field Values

STREAMS_DEFINITION

public static final int STREAMS_DEFINITION

See Also:

Constant Field Values

STREAM_PROPERTY

public static final int STREAM_PROPERTY

See Also:

Constant Field Values

SESSION_CLOSED

public static final int SESSION_CLOSED

See Also:

Constant Field Values

SESSION_STARTED

public static final int SESSION_STARTED

See Also:

Constant Field Values

STREAMS_CHANGED

public static final int STREAMS_CHANGED

See Also:

Constant Field Values

AF_STUB_STREAM

public static final int AF_STUB_STREAM

See Also:

Constant Field Values

TRANSPORT_TYPE_SOCKET

public static final byte TRANSPORT_TYPE_SOCKET

See Also:

Constant Field Values

TRANSPORT_TYPE_AERON

public static final byte TRANSPORT_TYPE_AERON

See Also:

Constant Field Values

Constructor Detail

TDBProtocol

public TDBProtocol()

Method Detail

getSSLPort

public static int getSSLPort(int port)

getPort

public static int getPort(int port,
                          boolean ssl)

getHttpProtocol

public static java.lang.String getHttpProtocol(boolean ssl)

getProtocol

public static java.lang.String getProtocol(boolean ssl)

isSSL

public static boolean isSSL(java.lang.String protocol)

writeParameters

public static void writeParameters(Parameter[] params,
                                   java.io.DataOutputStream out)
                            throws java.io.IOException

Throws:

java.io.IOException

readParameters

public static Parameter[] readParameters(java.io.DataInputStream in,
                                         int clientVersion)
                                  throws java.io.IOException

Throws:

java.io.IOException

writeTransformationTask

public static void writeTransformationTask(TransformationTask task,
                                           java.io.DataOutputStream out)
                                    throws java.io.IOException

Throws:

java.io.IOException

readTransformationTask

public static TransformationTask readTransformationTask(java.io.DataInputStream in)
                                                 throws java.io.IOException

Throws:

java.io.IOException

writeTimeRange

public static void writeTimeRange(long[] range,
                                  java.io.DataOutputStream out)
                           throws java.io.IOException

Throws:

java.io.IOException

writeTimeRange

public static void writeTimeRange(deltix.qsrv.hf.pub.TimeInterval range,
                                  java.io.DataOutputStream out)
                           throws java.io.IOException

Throws:

java.io.IOException

readTimeRangeLong

public static long[] readTimeRangeLong(java.io.DataInputStream in)
                                throws java.io.IOException

Throws:

java.io.IOException

writeBGProcessInfo

public static void writeBGProcessInfo(BackgroundProcessInfo info,
                                      java.io.DataOutputStream out)
                               throws java.io.IOException

Throws:

java.io.IOException

readBGProcessInfo

public static BackgroundProcessInfo readBGProcessInfo(java.io.DataInputStream in)
                                               throws java.io.IOException,
                                                      java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

writeClassSet

public static void writeClassSet(java.io.DataOutputStream out,
                                 ClassSet set)
                          throws java.io.IOException

Throws:

java.io.IOException

toString

public static java.lang.String toString(RecordClassSet md)
                                 throws java.io.IOException

Throws:

java.io.IOException

readClassSet

public static ClassSet readClassSet(java.lang.String in)

readClassSet

public static ClassSet readClassSet(java.io.DataInputStream in)
                             throws java.io.IOException

Throws:

java.io.IOException

writeTimeRange

public static void writeTimeRange(java.io.DataOutputStream out,
                                  DXTickStream stream,
                                  deltix.qsrv.hf.pub.InstrumentIdentity[] ids)
                           throws java.io.IOException

Throws:

java.io.IOException

writeStream

public static void writeStream(java.io.DataOutputStream out,
                               DXTickStream stream,
                               int clientVersion)
                        throws java.io.IOException

Throws:

java.io.IOException

writeStreamOptions

public static void writeStreamOptions(java.io.DataOutputStream out,
                                      StreamOptions so,
                                      int clientVersion)
                               throws java.io.IOException

Throws:

java.io.IOException

readStreamOptions

public static StreamOptions readStreamOptions(java.io.DataInputStream in,
                                              int clientVersion)
                                       throws java.io.IOException

Throws:

java.io.IOException

readStreamOptions76

public static StreamOptions readStreamOptions76(java.io.DataInputStream in)
                                         throws java.io.IOException

Throws:

java.io.IOException

writeNonNullableStrings

public static void writeNonNullableStrings(java.io.DataOutputStream out,
                                           java.lang.String[] strings)
                                    throws java.io.IOException

Throws:

java.io.IOException

readNonNullableStrings

public static java.lang.String[] readNonNullableStrings(java.io.DataInputStream in)
                                                 throws java.io.IOException

Throws:

java.io.IOException

writeNullableStringArray

public static void writeNullableStringArray(java.io.DataOutputStream out,
                                            @Nullable
                                            java.lang.String[] strings)
                                     throws java.io.IOException

Throws:

java.io.IOException

writeNullableStringArray

public static void writeNullableStringArray(java.io.DataOutputStream out,
                                            @Nullable
                                            java.util.List<java.lang.CharSequence> strings)
                                     throws java.io.IOException

Throws:

java.io.IOException

readNullableStringArray

@Nullable
public static java.lang.String[] readNullableStringArray(java.io.DataInputStream din)
                                                  throws java.io.IOException

Throws:

java.io.IOException

writeCredentials

public static void writeCredentials(VSChannel channel,
                                    UserPrincipal principal)
                             throws java.io.IOException

Throws:

java.io.IOException

writeCredentials

public static void writeCredentials(VSChannel channel,
                                    UserPrincipal principal,
                                    java.security.Principal delegate)
                             throws java.io.IOException

Throws:

java.io.IOException

writeBinary

public static void writeBinary(java.io.DataOutputStream out,
                               java.lang.Throwable e)
                        throws java.io.IOException

Throws:

java.io.IOException

readBinary

public static java.lang.Throwable readBinary(java.io.DataInputStream in)
                                      throws java.io.IOException,
                                             java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

writeError

public static void writeError(java.io.DataOutputStream out,
                              java.lang.Throwable e)
                       throws java.io.IOException

Throws:

java.io.IOException

readError

public static java.lang.Throwable readError(java.io.DataInputStream in)
                                     throws java.io.IOException,
                                            java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

readError

public static java.lang.Throwable readError(java.io.DataInputStream in,
                                            ExceptionResolver resolver)
                                     throws java.io.IOException,
                                            java.lang.ClassNotFoundException

Throws:

java.io.IOException

java.lang.ClassNotFoundException

readCredentials

public static UserCredentials readCredentials(VSChannel channel)
                                       throws java.io.IOException

Throws:

java.io.IOException