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

Catherine Wong

I cannot find any example application in RFA Java software
package to parse page data e.g. RIC 3323bk.HKd.

pimchaya.wongrukun01

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: