I need an example application using MarketData/TibMsg interface to parse page data

Hello @Catherine Wong

The page data can be updated partially. Therefore, the application requires additional steps for processing an update message to display the correct data of the field.

Normally, updates to specific fields would be accomplished by sending the whole data field; however with some large fields this can be inefficient when only a few characters within the data field are to be updated. In such cases the publishing application sends an intra-field positioning sequence within the data field so that the minimum number of characters are transmitted to effect a change.

The syntax of an intra-field positioning sequence is as follows:

<CSI>n<HPA>

Where:

• <CSI> is the control sequence introducer (this can be a one or two-byte sequence, either Hex 9B or Hex 1b 5b)

• n is an ASCII numeric string representing the cursor offset position relative to the start of the field.

• <HPA> is the Horizontal Position Adjust character which terminates the intra-field position sequence (Hex 60 which is an ASCII “ ‘ ”).

The 0x60 byte signals the termination of the partial update positioning sequence. n is a set of numeric digits (0x30 through 0x39) that represent the byte offset position relative to the start of the field. Counting begins with the first byte position being number 0 (zero).

For example, the application receives a refresh message with the field id 318 is:

 4087   -1s  4409  8578 |  3349  3268  8038  8738   

and the following hex update is received:

1b 5b 37 60 38 35 37 37 20 20 33 30 37 37 20 20 36 34 33

The update means update the field at position 7 with “8577 3077 643”

Then after the update is processed, the data of the field id 318 that the application should display is:

 4087  8577  3077  6438 |  3349  3268  8038  8738

The intra-field positioning sequence is supported for fields of the ALPHANUMERIC type.

TibMsg Interface used by MarketData applications provides the following class/constant that helps to interpret partial update:

• TibMsg.TIBMSG_PARTIAL: Indicates data is partial field type containing offset and content(updated value). Use the class TibPartial for casting and dereference of this type of data.
• TibPartial : provide methods to get offset(TibPartial.offset) and content(TibPartial.contents) in an partial update message.

Unfortunately, there is no MarketData example application shipped with RFA Java package to process partial updates. However, you can modify the file named MDSubDemoClient.java in MDSubDemo application located in <RFAJ_Package>\Legacy\Examples\com\reuters\rfa\legacyexample\session\mdsub to use the class/constant above to process partial update.

The example source code of modified MDSubDemoClient.java to process partial and full update is below:

public class MDSubDemoClient implements Client
{
    private final MDSubDemo _application;
    TibMsg msg = new TibMsg();
    TibField field = new TibField();
    //The map which keeps the fields(Field id & Value) to be updated
    Map<Integer,String> pageFields;
    …
    public MDSubDemoClient(MDSubDemo subDemo)
    {
        _application = subDemo;
        //initialize the map which keeps fields to be updated
        pageFields = new TreeMap<Integer,String>();
    }
    …
    protected void processMarketDataItemEvent(MarketDataItemEvent marketDataItemEvent)
    {
      …
      if (dict.fhint == Tib.HINT_MFEED_ENUMERATED)
      {
      	…
      }  
      else 
        //System.out.println(field.StringData());
        {  // if the field is not Enumerated type
         if( field.Type() == TibMsg.TIBMSG_PARTIAL ) 
         //update partial field
         { 
          TibPartial p = (TibPartial)field.Data();
          String updateStr = new String(p.contents);
          int offset = p.offset; //offset starts from 0
          System.out.println("fieldId:"+fid + ", offset:"+ offset + ", updateString:" + updateStr);
          StringBuilder value = new StringBuilder(pageFields.get(fid));
          value.replace(offset, offset+updateStr.length(), updateStr);
          pageFields.put(fid, value.toString());
         } 
         else {//update whole field
           pageFields.put(fid, field.StringData());
         }
        }
        …
      System.out.println();
      //display the page after updating all fields of the page
      System.out.println("**********************Updated Page***************************************");
      for (Integer fieldId: pageFields.keySet()){
         System.out.print(fieldId+":");
         System.out.println(pageFields.get(fieldId).toString());  
      }
    }

The example command line to run MDSubDemo 5 minutes(300 seconds) with a user named pimchaya to subscribe a RIC named 3323bk.HKd to the service named ELEKTRON_NEON on the server configured in a consumer session(connection type is SSL) named SSLNamespace::pageSSLSession:

java -cp .;..\..\Libs\rfa.jar com.reuters.rfa.legacyexample.session.mdsub.MDSubDemo -session SSLNamespace::pageSSLSession -serviceName ELEKTRON_NEON -itemName 3323bk.HKd -mounttpi true -user pimchaya -runTime 300

For the help of MDSubDemo, please refer to package.html in <RFAJ_Package>\Legacy\Examples\com\reuters\rfa\legacyexample\session\mdsub

The example output: