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)