Have created server side solution using EMA API for fetching prices. The service gets stalled after sending batch request with exception noted below. The issue occurs intermittently and required restart of application.

Question

question

malika.gupta

1 ●1 ●1 ●5

Have created server side solution using EMA API for fetching prices. The service gets stalled after sending batch request with exception noted below. The issue occurs intermittently and required restart of application.

The issue is not reproducable, occuring intermittently. The program gets halted and requires restart of full application.

Getting below Exception:

2017-06-07T11:58:10.217+05:30 [APP/0] [ERR] Exception in thread "pool-2-thread-1" java.lang.NullPointerException 2017-06-07T11:58:10.218+05:30 [APP/0] [ERR] at com.thomsonreuters.ema.access.SingleItem.remove(Unknown Source) 2017-06-07T11:58:10.218+05:30 [APP/0] [ERR] at com.thomsonreuters.ema.access.ItemCallbackClient.defaultMsgCallback(Unknown Source) 2017-06-07T11:58:10.218+05:30 [APP/0] [ERR] at com.thomsonreuters.ema.access.ItemCallbackClient.processRefreshMsg(Unknown Source) 2017-06-07T11:58:10.218+05:30 [APP/0] [ERR] at com.thomsonreuters.upa.valueadd.reactor.Reactor.sendDefaultMsgCallback(Reactor.java:808) 2017-06-07T11:58:10.218+05:30 [APP/0] [ERR] at com.thomsonreuters.upa.valueadd.reactor.Reactor.sendAndHandleDefaultMsgCallback(Reactor.java:823) 2017-06-07T11:58:10.219+05:30 [APP/0] [ERR] at com.thomsonreuters.upa.valueadd.reactor.WlItemHandler.callbackUser(WlItemHandler.java:2663) 2017-06-07T11:58:10.219+05:30 [APP/0] [ERR] at com.thomsonreuters.upa.valueadd.reactor.WlItemHandler.readMsg(WlItemHandler.java:1704) 2017-06-07T11:58:10.219+05:30 [APP/0] [ERR] at com.thomsonreuters.upa.valueadd.reactor.WlItemHandler.readRefreshMsg(WlItemHandler.java:1950) 2017-06-07T11:58:10.219+05:30 [APP/0] [ERR] at com.thomsonreuters.upa.valueadd.reactor.Watchlist.readMsg(Watchlist.java:277) 2017-06-07T11:58:10.219+05:30 [APP/0] [ERR] at com.thomsonreuters.upa.valueadd.reactor.Reactor.dispatchAll(Reactor.java:3217) 2017-06-07T11:58:10.219+05:30 [APP/0] [ERR] at com.thomsonreuters.upa.valueadd.reactor.Reactor.performChannelRead(Reactor.java:1750) 2017-06-07T11:58:10.220+05:30 [APP/0] [ERR] at com.thomsonreuters.ema.access.OmmBaseImpl.rsslReactorDispatchLoop(Unknown Source) 2017-06-07T11:58:10.220+05:30 [APP/0] [ERR] at com.thomsonreuters.ema.access.OmmBaseImpl.run(Unknown Source) 2017-06-07T11:58:10.220+05:30 [APP/0] [ERR] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) 2017-06-07T11:58:10.220+05:30 [APP/0] [ERR] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) 2017-06-07T11:58:10.220+05:30 [APP/0] [ERR] at java.lang.Thread.run(Thread.java:748)

Any leads on this?

Also the exchange rate we are fetching from EMA gives pricision upti 4 decimal places only. The same we get from RFA with higher rate of precision, Any suggestion how can we increase the precison using EMA, since our calculations are getting impacted.

elektron refinitiv-realtime elektron-sdk ema-api rrt elektron-message-api batch

Jun 07, 2017 at 05:03 AM

10 |1500

Attachments: Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

moragodkrit.chumsri_1 Jun 07, 2017 at 05:13 AM

Monitored by @Wasin Waeosri

wasin.w Jun 29, 2017 at 11:22 PM

We have created the TRDC case 05593559 to investigate this issue in detail.

pimchaya.wongrukun01 Jul 21, 2017 at 02:11 AM

Please be informed that a reply has been verified as correct in answering the question, and has been marked as such.
Thanks,
AHS

Answer 1 · 2017-07-14T01:31:30Z

wasin.w

24.7k ●54 ●17 ●14

Update: The client cannot replicate this issue after upgrade the API to Elektron SDK 1.1.0

Jul 14, 2017 at 01:31 AM

10 |1500

Attachments: Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

Answer 2 · 2017-06-08T05:18:15Z

wasin.w

24.7k ●54 ●17 ●14

Hi @malika.gupta

What is the EMA Java version that encounter problems?

For the exception issue, could you please give us a snippet code of your application that interacts with EMA Java
For the decimal issue, could you please give us example RICs that encounter the problem?

Jun 08, 2017 at 05:18 AM

10 |1500

Attachments: Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

malika.gupta Jun 12, 2017 at 07:23 AM

@Wasin Waeosri comment added

Answer 3 · 2017-06-12T01:57:39Z

malika.gupta

1 ●1 ●1 ●5

This is the snippet that registers the batch request with EMA :

  RFAMarketDataResponse dataResponse = null;
        try {
            RfaClient appClient = new RfaClient(countDown);
            ReqMsg reqMsg = createBatchRequestMsg(rfaRequest);
            if (null == ommConsumer) {
                throw new RealTimeDataNotAvailableException(
                        REAL_TIME_DATA_AVAILABLE.getMessage(), null);
            }
            LOGGER.info("Calling EMA service started on: " + new Date());
            long startMillis = System.currentTimeMillis();
            ommConsumer.registerClient(reqMsg, appClient);
            boolean taskCompleted = countDown
                    .await(marketDataConfig.rfaTimeOut, TimeUnit.SECONDS);
            if (!taskCompleted) {
                LOGGER.error(
                        "Maximum time elapsed for the EMA service, "
                        + "Please check the curernt timeout limit: "
                                + marketDataConfig.rfaTimeOut);
                throw new BusinessException(
                        MessageCodes.REQUEST_TIMEOUT.getCode());
            }
            dataResponse = appClient.getResponse();

And this is the one that captures the response : callback and decodes the response:

   MarketDataField dataField = new MarketDataField();
        try {
            String name = refreshMsg.name();
            dataField.setItemName(name);
            if (DataType.DataTypes.FIELD_LIST == refreshMsg
                    .payload()
                        .dataType()) {
                decode(refreshMsg.payload().fieldList(), dataField);
            }
            LOGGER.debug("Market Data response received: "
                    + System.currentTimeMillis());
        } catch (BusinessException e) {
            dataField.setError(new MarketDataError(
                    MessageCodes.UNKNOWN_ERROR.getCode(), null));
        } finally {
            countDown.countDown();
        }

We are creating single ommconsumer at app start up that makes the connection and serves multiple requests.

We are using Elektron-SDK1.0.8.java

Jun 12, 2017 at 01:57 AM

10 |1500

Attachments: Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

wasin.w Jun 14, 2017 at 12:08 AM

@malika.gupta, I have created the case TRDC 05593559 to investigate this issue. I will send you update via a separate email.

Q&A Forum

question

Have created server side solution using EMA API for fetching prices. The service gets stalled after sending batch request with exception noted below. The issue occurs intermittently and required restart of application.

3 Answers

Write an Answer

question

Have created server side solution using EMA API for fetching prices. The service gets stalled after sending batch request with exception noted below. The issue occurs intermittently and required restart of application.

3 Answers

Write an Answer

Related Questions