Package io.deephaven.sbe.standalone.client

Interface SimpleMessageHandlerListener

public interface SimpleMessageHandlerListener
Clients should implement this to receive decoded messages from the SimpleMessageHandler.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    onBeginTableUpdate(int subscriptionId)
    Implement this method to receive notification of the start of a table data update.
    void
    onConnectionError(IOException ex)
    Occurs when an unexpected IO error occurs with the client connection, preceding client death.
    void
    onEndTableUpdate(int subscriptionId)
    Implement this method to receive notification of the end of a table data update.
    void
    onRowsAdded(int subscriptionId, int columnId, long[] rows, Object[] values, int nRows)
    Implement this method to receive notification of rows added to a column.
    void
    onRowsModified(int subscriptionId, int columnId, long[] rows, Object[] values, int nRows)
    Implement this method to receive notification of modified rows in a column.
    void
    onRowsRemoved(int subscriptionId, long[] rows, int nRows)
    Implement this method to receive notification of rows removed from a table.
    void
    onSubscribeResponse(int subscriptionId, Map<Integer,ColumnInfo> columnData)
    Implement this method to receive notification of subscription confirmation messages.
    void
    onSubscriptionError(int subscriptionId, TableSubscriptionErrorCode errorCode, String errorMessage)
    Implement this method to receive notification of errors related to subscriptions.
    void
    onUnsubscribeResponse(int subscriptionId)
    Implement this method to receive notification of unsubscribe confirmation messages.

  • Method Details

    • onConnectionError

      void onConnectionError(IOException ex)
      Occurs when an unexpected IO error occurs with the client connection, preceding client death.
      Parameters:
      ex - The error that resulted in this notification.

    • onSubscribeResponse

      void onSubscribeResponse(int subscriptionId, Map<Integer,ColumnInfo> columnData)
      Implement this method to receive notification of subscription confirmation messages.
      Parameters:
      subscriptionId - The subscription identifier
      columnData - Column information for the subscribed table

    • onUnsubscribeResponse

      void onUnsubscribeResponse(int subscriptionId)
      Implement this method to receive notification of unsubscribe confirmation messages.
      Parameters:
      subscriptionId - The subscription identifier

    • onSubscriptionError

      void onSubscriptionError(int subscriptionId, TableSubscriptionErrorCode errorCode, String errorMessage)
      Implement this method to receive notification of errors related to subscriptions.
      Parameters:
      subscriptionId - The subscription identifier
      errorCode - Error code
      errorMessage - Textual description of the error

    • onBeginTableUpdate

      void onBeginTableUpdate(int subscriptionId)
      Implement this method to receive notification of the start of a table data update.
      Parameters:
      subscriptionId - The subscription identifier

    • onEndTableUpdate

      void onEndTableUpdate(int subscriptionId)
      Implement this method to receive notification of the end of a table data update.
      Parameters:
      subscriptionId - The subscription identifier

    • onRowsAdded

      void onRowsAdded(int subscriptionId, int columnId, long[] rows, Object[] values, int nRows)
      Implement this method to receive notification of rows added to a column.
      Parameters:
      subscriptionId - The subscription identifier
      columnId - Affected column
      rows - Array of row indexes affected by this update
      values - Array of values corresponding to the rows
      nRows - Number of rows (nRows-1 is the last valid index in rows and values)

    • onRowsModified

      void onRowsModified(int subscriptionId, int columnId, long[] rows, Object[] values, int nRows)
      Implement this method to receive notification of modified rows in a column.
      Parameters:
      subscriptionId - The subscription identifier
      columnId - Affected column
      rows - Array of row indexes affected by this update
      values - Array of values corresponding to the rows
      nRows - Number of rows (nRows-1 is the last valid index in rows and values)

    • onRowsRemoved

      void onRowsRemoved(int subscriptionId, long[] rows, int nRows)
      Implement this method to receive notification of rows removed from a table.
      Parameters:
      subscriptionId - The subscription identifier
      rows - Array of row indexes affected by this update
      nRows - Number of rows (nRows-1 is the last valid index in rows)