Receiving market data from RMDS using Real-Time SDK - Java Enterprise Transport API

Sweetu

Hi,

We are using Real-Time SDK - Java Enterprise Transport API (Real-Time-SDK-2.3.1.L1.java.zip) for receiving market data i.e. FX currency rates from RMDS. We have used consumer.java from examples folder of the API. We need help in below points.

1. Currently we are receiving multiple field data for a RIC code. We just want only “Bid”, “Ask” and “Size” fields. How to configure only required field ID/name for which we want.
2. Currently we have set “INR=“ RIC Code as default item and hence receiving only data for this RIC. How can we configure and receive data for multiple RIC codes.
3. Currently seems like we are receiving rates from RMDS only once and not receiving rates as and when there are new updates. How can we receive rates post subscribing for it and RMDS continuously publish after subscribing.
4. Also it is observed after sometime the session gets disconnected automatically.

For reference I am attaching the java code file and logs of our implementation. Can someone please help in addressing above issue. Thanks in advance.

Regards.

Sweetu.

Consumer.java.txt

logs.rtf.txt

Jirapongse

@Sweetu

Thank you for reaching out to us.

The Consumer application is provided as an example to demonstrate how to use the ETA API for consuming data from RTDS or a data feed. It is not recommended to use the Example in a production environment. Use it as a reference and consult the ETA Developer Guide for detailed information.

1.The example supports the view request by using the -view parameter but you need to modify the code (MarketPriceHandler.java) to request those fields.

-view viewFlag. Default is false. If true, each request will use a basic dynamic view.

For example:

    protected MarketPriceHandler(int domainType, StreamIdWatchList watchList)

    {

        this.watchList = watchList;

        this.domainType = domainType;

        marketPriceRequest = createMarketPriceRequest();

        closeMessage = new MarketPriceClose();

        viewFieldList = new ArrayList<String>();

        viewFieldList.add("22");

        viewFieldList.add("25");

        viewFieldList.add("30");

        viewFieldList.add("31");

    }

FID 22 is BID, FID 25 is ASK, FID 30 is BIDSIZE, and FID 31 is ASKSIZE. Then, you need to run the example with the -view parameter. For example:

-h 192.168.42.195 -p 14002 -mp INR= -s ELEKTRON_DD -view

2. The example supports multiple subscriptions by using the multiple -mp parameters.

-mp Market Price domain item name. Default is <i>TRI.N</i>. The user can

 * specify multiple -mp instances, where each occurrence is associated with a

 * single item. For example, specifying -mp TRI -mp GOOG will provide content

 * for two MarketPrice items.

For example:

-h 192.168.42.195 -p 14002 -mp INR= -mp JPY= -s ELEKTRON_DD -view

3. I ran the example and could retrieve the updates of INR=.

INR=

DOMAIN: MARKET_PRICE

State: Open/Ok/None - text: ""

	22/BID: 89.2112

	25/ASK: 89.2312


INR= 

DOMAIN: MARKET_PRICE

UPDATE TYPE: UNSPECIFIED

	22/BID: 89.2100

	25/ASK: 89.2300


INR= 

DOMAIN: MARKET_PRICE

UPDATE TYPE: UNSPECIFIED

	22/BID: 89.2088

	25/ASK: 89.2288

4. By default, the example will run for 600 seconds and then exit. You can use the -runtime parameter to increase its runtime.

 -runtime run time. Default is 600 seconds. Controls the time the

 * application will run before exiting, in seconds.