class O2GMessagesTable

Brief

The class keeps in memory the up-to-date information about dealing desk messages received during the current trading day.

Details

The class is an in-memory representation of the Messages table.
In order to keep this representation in sync with the trading server, you must instantiate the class and listen to the updates coming from the trading server. The class provides methods to find individual messages, represented by the O2GMessageTableRow.

Prerequisites

The class is available only through the use of the O2GTableManager. An O2GTableManager object must have the O2GTableManagerStatus.TABLES_LOADED status.
For complete instructions on the table manager usage, see the How to use table manager in ForexConnect API section.

Instantiating the class

In order to get messages information for the first time, you must obtain an instance of the class by calling the O2GTableManager.getTable method with the O2GTableType.MESSAGES argument. For example,

O2GMessagesTable messagesTable = (O2GMessagesTable)tableManager.getTable(O2GTableType.MESSAGES);

Receiving notifications about the Messages table updates

In order to keep the O2GMessagesTable data current, your application must listen to the new messages coming from the trading server. An instance of the class implementing the IO2GTableListener interface must be subscribed to the table update of the O2GTableUpdateType.INSERT type. Before the logout, you must unsubscribe the listener from this update type. The table below shows the subscription/unsubsription syntax for the O2GMessagesTable:

Note: Messages are not changed or deleted during the trading session. Therefore, you do not receive updates of the UPDATE or DELETE types during the trading session and there is no need to subscribe to them.

Example

    // Get the instance of table manager
    O2GTableManager tableManager = mSession.getTableManager();
    while (tableManager.getStatus() != O2GTableManagerStatus.TABLES_LOADED &
           tableManager.getStatus() != O2GTableManagerStatus.TABLES_LOAD_FAILED) {
        Thread.sleep(50);
    }
 
    // Get messages information
    if (tableManager.getStatus() == O2GTableManagerStatus.TABLES_LOADED) {
        O2GMessagesTable messageTable = (O2GMessagesTable)tableManager.getTable(O2GTableType.MESSAGES);
        for (int i = 0; i < messageTable.size(); i++) {
            O2GMessageTableRow message = messageTable.getRow(i);
            System.out.println("From: " + message.getFrom() +
                               " Text = " + message.getText());
        }
 
        // Subscribe table listener
        TableListener tableListener = new TableListener();
        messageTable.subscribeUpdate(O2GTableUpdateType.INSERT, tableListener);
        Thread.sleep(1000);
        messageTable.unsubscribeUpdate(O2GTableUpdateType.INSERT, tableListener);
    }
 
     // Implementation of IO2GTableListener interface public method onAdded
     public void onAdded(String rowID, O2GRow rowData) {
     O2GMessageTableRow message = (O2GMessageTableRow)(rowData);
     System.out.println("Message information added " + rowID);
     System.out.println("From: " + message.getFrom() +
                        " Text = " + message.getText());
    }

The namespace is com.fxcore2.