Package io.deephaven.sbe.standalone.client

Class TableClient.Receiver

java.lang.Object

io.deephaven.sbe.standalone.client.TableClient.Receiver

All Implemented Interfaces:

Runnable

Enclosing class:

TableClient

protected class TableClient.Receiver
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
protected final BeginTableUpdateDecoder	beginTableUpdateDecoder
protected final BooleanArrayColumnDataDecoder	booleanArrayColumnDataDecoder
protected final BooleanColumnDataDecoder	booleanColumnDataDecoder
protected final ByteArrayColumnDataDecoder	byteArrayColumnDataDecoder
protected final ByteColumnDataDecoder	byteColumnDataDecoder
protected final CharArrayColumnDataDecoder	charArrayColumnDataDecoder
protected final CharColumnDataDecoder	charColumnDataDecoder
protected final ConnectionResponseDecoder	connectionResponseDecoder
protected final DateTimeColumnDataDecoder	dateTimeColumnDataDecoder
protected final DecimalColumnDataDecoder	decimalColumnDataDecoder
protected final DoubleArrayColumnDataDecoder	doubleArrayColumnDataDecoder
protected final DoubleColumnDataDecoder	doubleColumnDataDecoder
protected final EndTableUpdateDecoder	endTableUpdateDecoder
protected final FloatArrayColumnDataDecoder	floatArrayColumnDataDecoder
protected final FloatColumnDataDecoder	floatColumnDataDecoder
protected static final int	INIT_RECV_MSG_BUFFER_SIZE
protected final IntArrayColumnDataDecoder	intArrayColumnDataDecoder
protected final IntColumnDataDecoder	intColumnDataDecoder
protected final LongArrayColumnDataDecoder	longArrayColumnDataDecoder
protected final LongColumnDataDecoder	longColumnDataDecoder
protected final MessageHandler	messageHandler
protected final MessageHeaderDecoder	messageHeaderDecoder
protected final RowsRemovedDecoder	rowsRemovedDecoder
protected final ShortArrayColumnDataDecoder	shortArrayColumnDataDecoder
protected final ShortColumnDataDecoder	shortColumnDataDecoder
protected boolean	stop
protected final StringArrayColumnDataDecoder	stringArrayColumnDataDecoder
protected final StringColumnDataDecoder	stringColumnDataDecoder
protected final StringSetColumnDataDecoder	stringSetColumnDataDecoder
protected final TableSubscriptionErrorDecoder	subscriptionErrorDecoder
protected final TableSubscribeResponseDecoder	subscriptionResponseDecoder
protected final TableUnsubscribeResponseDecoder	unsubscribeResponseDecoder

Method Summary

Modifier and Type	Method	Description
protected void	blockingRead(ByteBuffer dst)
void	run()

Methods inherited from class java.lang.Object

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

Field Details

INIT_RECV_MSG_BUFFER_SIZE

protected static final int INIT_RECV_MSG_BUFFER_SIZE

See Also:

• Constant Field Values

connectionResponseDecoder

protected final ConnectionResponseDecoder connectionResponseDecoder

messageHeaderDecoder

protected final MessageHeaderDecoder messageHeaderDecoder

subscriptionResponseDecoder

protected final TableSubscribeResponseDecoder subscriptionResponseDecoder

unsubscribeResponseDecoder

protected final TableUnsubscribeResponseDecoder unsubscribeResponseDecoder

subscriptionErrorDecoder

protected final TableSubscriptionErrorDecoder subscriptionErrorDecoder

beginTableUpdateDecoder

protected final BeginTableUpdateDecoder beginTableUpdateDecoder

endTableUpdateDecoder

protected final EndTableUpdateDecoder endTableUpdateDecoder

byteColumnDataDecoder

protected final ByteColumnDataDecoder byteColumnDataDecoder

booleanColumnDataDecoder

protected final BooleanColumnDataDecoder booleanColumnDataDecoder

intColumnDataDecoder

protected final IntColumnDataDecoder intColumnDataDecoder

longColumnDataDecoder

protected final LongColumnDataDecoder longColumnDataDecoder

stringColumnDataDecoder

protected final StringColumnDataDecoder stringColumnDataDecoder

decimalColumnDataDecoder

protected final DecimalColumnDataDecoder decimalColumnDataDecoder

doubleColumnDataDecoder

protected final DoubleColumnDataDecoder doubleColumnDataDecoder

floatColumnDataDecoder

protected final FloatColumnDataDecoder floatColumnDataDecoder

shortColumnDataDecoder

protected final ShortColumnDataDecoder shortColumnDataDecoder

charColumnDataDecoder

protected final CharColumnDataDecoder charColumnDataDecoder

byteArrayColumnDataDecoder

protected final ByteArrayColumnDataDecoder byteArrayColumnDataDecoder

booleanArrayColumnDataDecoder

protected final BooleanArrayColumnDataDecoder booleanArrayColumnDataDecoder

charArrayColumnDataDecoder

protected final CharArrayColumnDataDecoder charArrayColumnDataDecoder

doubleArrayColumnDataDecoder

protected final DoubleArrayColumnDataDecoder doubleArrayColumnDataDecoder

floatArrayColumnDataDecoder

protected final FloatArrayColumnDataDecoder floatArrayColumnDataDecoder

intArrayColumnDataDecoder

protected final IntArrayColumnDataDecoder intArrayColumnDataDecoder

longArrayColumnDataDecoder

protected final LongArrayColumnDataDecoder longArrayColumnDataDecoder

shortArrayColumnDataDecoder

protected final ShortArrayColumnDataDecoder shortArrayColumnDataDecoder

stringArrayColumnDataDecoder

protected final StringArrayColumnDataDecoder stringArrayColumnDataDecoder

dateTimeColumnDataDecoder

protected final DateTimeColumnDataDecoder dateTimeColumnDataDecoder

stringSetColumnDataDecoder

protected final StringSetColumnDataDecoder stringSetColumnDataDecoder

rowsRemovedDecoder

protected final RowsRemovedDecoder rowsRemovedDecoder

messageHandler

protected final MessageHandler messageHandler

stop

protected volatile boolean stop

Method Details

blockingRead

protected void blockingRead(ByteBuffer dst)
                     throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable