Package io.deephaven.sbe.standalone.client

Class SimpleMessageHandler

java.lang.Object
io.deephaven.sbe.standalone.client.SimpleMessageHandler
All Implemented Interfaces:
MessageHandler
public class SimpleMessageHandler extends Object implements MessageHandler
Simple message handler implementation that decodes incoming messages and does listener call-backs.

This example makes some effort to avoid excessive allocation by reusing buffers for incoming data but makes a compromise for convenience and still allocates for some immutable objects like Strings, BigDecimal, etc.

NOTE: this implementation is not thread safe. A unique instance must be passed to each concurrent TableClient.

  • Field Details

  • Constructor Details

    • SimpleMessageHandler

      public SimpleMessageHandler()
      Construct a new simple message handler.

  • Method Details

    • mapToChar

      protected char mapToChar(Object v)

    • getInstant

      protected Instant getInstant(long epochNanos)

    • addListener

      public void addListener(SimpleMessageHandlerListener listener)
      Add a listener to handle incoming decoded messages from the table server.
      Parameters:
      listener - The listener

    • handleConnectionError

      public void handleConnectionError(IOException ex)
      Handle a connection error by passing it on to any interested listeners.
      Specified by:
      handleConnectionError in interface MessageHandler
      Parameters:
      ex - The exception that resulted in this notification

    • decodeConnectionResponse

      public int decodeConnectionResponse(ConnectionResponseDecoder connectionResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode the connection response and allocate buffers according to the message buffer size indicated by the server.
      Specified by:
      decodeConnectionResponse in interface MessageHandler
      Parameters:
      connectionResponseDecoder - 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)
      Returns:
      message buffer size (decoded from the ConnectionResponse message)

    • decodeSubscribeResponse

      public void decodeSubscribeResponse(TableSubscribeResponseDecoder subscribeResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a SubscribeResponse message and pass along to interested listeners.
      Specified by:
      decodeSubscribeResponse in interface MessageHandler
      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

      public void decodeUnsubscribeResponse(TableUnsubscribeResponseDecoder unsubscribeResponseDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode an UnsubscribeResponse message and pass along to interested listeners.
      Specified by:
      decodeUnsubscribeResponse in interface MessageHandler
      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

      public void decodeSubscriptionError(TableSubscriptionErrorDecoder subscriptionErrorDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a SubscriptionError message and pass along to any interested listeners.
      Specified by:
      decodeSubscriptionError in interface MessageHandler
      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

      public void decodeBeginTableUpdate(BeginTableUpdateDecoder beginTableUpdateDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a BeginTableUpdate message and pass along to any interested listeners.
      Specified by:
      decodeBeginTableUpdate in interface MessageHandler
      Parameters:
      beginTableUpdateDecoder - 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

      public void decodeEndTableUpdate(EndTableUpdateDecoder endTableUpdateDecoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode an EndTableUpdate message and pass along to any interested listeners.
      Specified by:
      decodeEndTableUpdate in interface MessageHandler
      Parameters:
      endTableUpdateDecoder - 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

      public void decodeRowsRemoved(RowsRemovedDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a RowsRemoved message and pass along to any interested listeners.
      Specified by:
      decodeRowsRemoved in interface MessageHandler
      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

      public void decodeColumnUpdate(ByteColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a ByteColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(BooleanColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a BooleanColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(CharColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a CharColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(DoubleColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a DoubleColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(FloatColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a FloatColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(LongColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a LongColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(DateTimeColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a DateTimeColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(IntColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode an IntColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(ShortColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a ShortColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(ByteArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a ByteArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(BooleanArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a BooleanArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(CharArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a CharArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(DoubleArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a DoubleArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(FloatArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a FloatArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(IntArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode an IntArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(LongArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a LongArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(ShortArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a ShortArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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)

    • notifyListeners

      protected void notifyListeners(int subId, int colId, SimpleBool isModified, int nRows, int nData)

    • decodeColumnUpdate

      public void decodeColumnUpdate(DecimalColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a DecimalColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(StringColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a StringColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(StringArrayColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a StringArrayColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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

      public void decodeColumnUpdate(StringSetColumnDataDecoder decoder, org.agrona.concurrent.UnsafeBuffer directBuffer, int bufferOffset, int actingBlockLength, int actingVersion)
      Decode a StringSetColumnData message and pass along to any interested listeners.
      Specified by:
      decodeColumnUpdate in interface MessageHandler
      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)