com.illumon.iris.sbetransport.client

Interface MessageHandler

All Known Implementing Classes:

SimpleMessageHandler

public interface MessageHandler

Users of the TableClient must provide an implementation of this interface, which will get called in order to parse incoming messages. Each message type corresponds to a specific decoder, which is provided in the message handler. The implementation is responsible for calling "wrap" on the given message buffer and decoding the buffer in the correct order. In this way, the client can handle messages without the allocation of new objects, if that is desirable.

Method Summary

Modifier and Type	Method and Description
void	decodeBeginTableUpdate(BeginTableUpdateDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a BeginTableUpdate message.
void	decodeColumnUpdate(BooleanArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a BooleanArrayColumnData message.
void	decodeColumnUpdate(BooleanColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a BooleanColumnData message.
void	decodeColumnUpdate(ByteArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a ByteArrayColumnData message.
void	decodeColumnUpdate(ByteColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a ByteColumnData message.
void	decodeColumnUpdate(CharArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a CharArrayColumnData message.
void	decodeColumnUpdate(CharColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a CharColumnData message.
void	decodeColumnUpdate(DateTimeColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a DateTimeColumnData message.
void	decodeColumnUpdate(DecimalColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a DecimalColumnData message.
void	decodeColumnUpdate(DoubleArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a DoubleArrayColumnData message.
void	decodeColumnUpdate(DoubleColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a DoubleColumnData message.
void	decodeColumnUpdate(FloatArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a FloatArrayColumnData message.
void	decodeColumnUpdate(FloatColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a FloatColumnData message.
void	decodeColumnUpdate(IntArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode an IntArrayColumnData message.
void	decodeColumnUpdate(IntColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode an IntColumnData message.
void	decodeColumnUpdate(LongArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a LongArrayColumnData message.
void	decodeColumnUpdate(LongColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a LongColumnData message.
void	decodeColumnUpdate(ShortArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a ShortArrayColumnData message.
void	decodeColumnUpdate(ShortColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a ShortColumnData message.
void	decodeColumnUpdate(StringArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a StringArrayColumnData message.
void	decodeColumnUpdate(StringColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a StringColumnData message.
void	decodeColumnUpdate(StringSetColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a StringSetColumnData message.
int	decodeConnectionResponse(ConnectionResponseDecoder connectionResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) This handler must decode a ConnectionResponse message and return the message buffer size provided by the server.
void	decodeEndTableUpdate(EndTableUpdateDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode an EndTableUpdate message.
void	decodeRowsRemoved(RowsRemovedDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a RowsRemoved message.
void	decodeSubscribeResponse(TableSubscribeResponseDecoder subscribeResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a SubscribeResponse message.
void	decodeSubscriptionError(TableSubscriptionErrorDecoder subscriptionErrorDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode a SubscriptionError message.
void	decodeUnsubscribeResponse(TableUnsubscribeResponseDecoder unsubscribeResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion) Decode an UnsubscribeResponse message.
void	handleConnectionError(IOException ex) If an IO error is encountered while reading a message from the server, the TableClient will call this method and the user may handle it as appropriate, depending on the context.

Method Detail

handleConnectionError

void handleConnectionError(IOException ex)

If an IO error is encountered while reading a message from the server, the TableClient will call this method and the user may handle it as appropriate, depending on the context.

Parameters:

ex - The exception resulting in this notification

decodeConnectionResponse

int decodeConnectionResponse(ConnectionResponseDecoder connectionResponseDecoder,
                             org.agrona.concurrent.UnsafeBuffer directBuffer,
                             int bufferOffset,
                             int actingBlockLength,
                             int actingVersion)

This handler must decode a ConnectionResponse message and return the message buffer size provided by the server. This message provides the client with the maximum message size (in bytes). This must be returned to the caller, as it is used to allocate a fixed size buffer for subsequent messages. Only one ConnectionResponse message per client connection should occur, immediately after client first connects.

Parameters:

connectionResponseDecoder - Decoder which can be used to extract the message from from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

Returns:

message buffer size (decoded from the ConnectionResponse message)

decodeSubscribeResponse

void decodeSubscribeResponse(TableSubscribeResponseDecoder subscribeResponseDecoder,
                             org.agrona.concurrent.UnsafeBuffer directBuffer,
                             int bufferOffset,
                             int actingBlockLength,
                             int actingVersion)

Decode a SubscribeResponse message. The client will receive this after a successful subscription request. The subscription response contains metadata for the subscribed table.

Parameters:

subscribeResponseDecoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeUnsubscribeResponse

void decodeUnsubscribeResponse(TableUnsubscribeResponseDecoder unsubscribeResponseDecoder,
                               org.agrona.concurrent.UnsafeBuffer directBuffer,
                               int bufferOffset,
                               int actingBlockLength,
                               int actingVersion)

Decode an UnsubscribeResponse message. The client will receive this after a successful unsubscribe request.

Parameters:

unsubscribeResponseDecoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeSubscriptionError

void decodeSubscriptionError(TableSubscriptionErrorDecoder subscriptionErrorDecoder,
                             org.agrona.concurrent.UnsafeBuffer directBuffer,
                             int bufferOffset,
                             int actingBlockLength,
                             int actingVersion)

Decode a SubscriptionError message. The client will receive this after an error with a new subscription request or if an error occurs while publishing table updates to the client.

Parameters:

subscriptionErrorDecoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeBeginTableUpdate

void decodeBeginTableUpdate(BeginTableUpdateDecoder decoder,
                            org.agrona.concurrent.UnsafeBuffer directBuffer,
                            int bufferOffset,
                            int actingBlockLength,
                            int actingVersion)

Decode a BeginTableUpdate message. The client will receive this message at the beginning of a table update. Table updates are bracketed with BeginTableUpdate and EndTableUpdate messages, since the volume of data for an update can be arbitrarily large.

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeEndTableUpdate

void decodeEndTableUpdate(EndTableUpdateDecoder decoder,
                          org.agrona.concurrent.UnsafeBuffer directBuffer,
                          int bufferOffset,
                          int actingBlockLength,
                          int actingVersion)

Decode an EndTableUpdate message. The client will receive this message at the beginning of a table update. Table updates are bracketed with BeginTableUpdate and EndTableUpdate messages, since the volume of data for an update can be arbitrarily large.

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeRowsRemoved

void decodeRowsRemoved(RowsRemovedDecoder decoder,
                       org.agrona.concurrent.UnsafeBuffer directBuffer,
                       int bufferOffset,
                       int actingBlockLength,
                       int actingVersion)

Decode a RowsRemoved message. The client will receive this message when rows are removed from a subscribed table. The indexes of the rows removed are indicated by a series of ranges. All columns are affected by this operation.

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(ByteColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a ByteColumnData message. The client will receive this message when rows are added/modified for a byte column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(BooleanColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a BooleanColumnData message. The client will receive this message when rows are added/modified for a Boolean column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(CharColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a CharColumnData message. The client will receive this message when rows are added/modified for a char column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(DoubleColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a DoubleColumnData message. The client will receive this message when rows are added/modified for a double column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(FloatColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a FloatColumnData message. The client will receive this message when rows are added/modified for a float column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(LongColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a LongColumnData message. The client will receive this message when rows are added/modified for a long column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(DateTimeColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a DateTimeColumnData message. The client will receive this message when rows are added/modified for a datetime column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order). Note that DateTimes are encoded as longs (nanos since the epoch).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(IntColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode an IntColumnData message. The client will receive this message when rows are added/modified for a int column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(ShortColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a ShortColumnData message. The client will receive this message when rows are added/modified for a short column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(DecimalColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a DecimalColumnData message. The client will receive this message when rows are added/modified for a fixed point decimal (BigDecimal in java) column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(StringColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a StringColumnData message. The client will receive this message when rows are added/modified for a String column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(StringArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a StringArrayColumnData message. The client will receive this message when rows are added/modified for a String[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(StringSetColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a StringSetColumnData message. The client will receive this message when rows are added/modified for a StringSet column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(BooleanArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a BooleanArrayColumnData message. The client will receive this message when rows are added/modified for a Boolean[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(ByteArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a ByteArrayColumnData message. The client will receive this message when rows are added/modified for a byte[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(CharArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a CharArrayColumnData message. The client will receive this message when rows are added/modified for a char[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(DoubleArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a DoubleArrayColumnData message. The client will receive this message when rows are added/modified for a double[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(FloatArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a FloatArrayColumnData message. The client will receive this message when rows are added/modified for a float[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(IntArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode an IntArrayColumnData message. The client will receive this message when rows are added/modified for a int[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(LongArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a LongArrayColumnData message. The client will receive this message when rows are added/modified for a long[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)

decodeColumnUpdate

void decodeColumnUpdate(ShortArrayColumnDataDecoder decoder,
                        org.agrona.concurrent.UnsafeBuffer directBuffer,
                        int bufferOffset,
                        int actingBlockLength,
                        int actingVersion)

Decode a ShortArrayColumnData message. The client will receive this message when rows are added/modified for a short[] column. The row indexes affected are encoded as a series of ranges, followed by the data (in the same order).

Parameters:

decoder - Decoder which can be used to extract the message from the given buffer

directBuffer - The underlying receive buffer

bufferOffset - The offset in the given buffer at which to start decoding

actingBlockLength - Block length from SBE header (pass to decoder wrap method)

actingVersion - Version from SBE header (pass to decoder wrap method)