question

Upvotes
Accepted
dumitru.arama avatar image
46 ●1 ●2 ●6

EMA issue with RTO connection

Hello,

A client is using Refinitiv Real-Time Optimized (RTO) datafeed. They are connecting with Location set to “us-east” (resolved to amer-3-t2.streaming-pricing-api.refinitiv.com). The client is using EMA API, sdk version: Elektron-SDK-1.5.0.G1.java. [ema-3.5.0.1.jar, upa-3.5.0.1.jar, upaValueAdd-3.5.0.1.jar]


After connecting and obtaining ChannelUp event, an exception is raised.


Here is the log:


24 Mar 2021 08:26:20,370 INFO [AlertService] AlertService: RateFeedAlertProcessor is starting ...

24 Mar 2021 08:26:20,422 INFO [AlertService] AlertService: RateFeedAlertProcessor started

24 Mar 2021 08:26:20,423 INFO [AlertService] AlertService: CallLevelAlertProcessor is starting ...

24 Mar 2021 08:26:20,433 INFO [AlertService] AlertService: CallLevelAlertProcessor started

24 Mar 2021 08:26:20,435 INFO [OmmConsumerImpl] loggerMsg

ClientName: ChannelCallbackClient

Severity: Info

Text: Received ChannelUp event on channel Channel_1

Instance Name Consumer_1_1

Component Version ads3.4.2.L1.linux.tis.rrg 64-bit

loggerMsgEnd



24 Mar 2021 08:26:21,502 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=GBP6M=,rateType=160,label=GBP/USD,contKey=5,tenor=6M,src_name=REFELSDK,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,505 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=CADSWR10=,rateType=39,label=USD/CAD,contKey=7,tenor=1W,src_name=REFELSDK,delta=10,type=Reversal/Call,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,507 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=GBPSW=,rateType=7,label=GBP/USD,contKey=5,tenor=1W,src_name=REFELSDK,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,510 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=EUR6MR10=,rateType=39,label=EUR/USD,contKey=1,tenor=6M,src_name=REFELSDK,delta=10,type=Reversal/Call,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,517 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=EUR6MB10=,rateType=39,label=EUR/USD,contKey=1,tenor=6M,src_name=REFELSDK,delta=10,type=Butterfly/Put,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,519 ERROR [stderr] Exception in thread "pool-17-thread-1" java.lang.ClassCastException: com.thomsonreuters.ema.access.ChannelDictionary cannot be cast to com.thomsonreuters.ema.access.Item

24 Mar 2021 08:26:21,520 ERROR [stderr] at com.thomsonreuters.ema.access.ItemCallbackClient.defaultMsgCallback(ItemCallbackClient.java:1498)

24 Mar 2021 08:26:21,520 ERROR [stderr] at com.thomsonreuters.upa.valueadd.reactor.Reactor.sendDefaultMsgCallback(Reactor.java:1371)

24 Mar 2021 08:26:21,521 ERROR [stderr] at com.thomsonreuters.upa.valueadd.reactor.Reactor.sendAndHandleDefaultMsgCallback(Reactor.java:1386)

24 Mar 2021 08:26:21,521 ERROR [stderr] at com.thomsonreuters.upa.valueadd.reactor.WlItemHandler.callbackUser(WlItemHandler.java:2940)

24 Mar 2021 08:26:21,522 ERROR [stderr] at com.thomsonreuters.upa.valueadd.reactor.WlItemHandler.readMsg(WlItemHandler.java:1984)

24 Mar 2021 08:26:21,522 ERROR [stderr] at com.thomsonreuters.upa.valueadd.reactor.Watchlist.readMsg(Watchlist.java:292)

24 Mar 2021 08:26:21,522 ERROR [stderr] at com.thomsonreuters.upa.valueadd.reactor.Reactor.performChannelRead(Reactor.java:2336)

24 Mar 2021 08:26:21,523 ERROR [stderr] at com.thomsonreuters.upa.valueadd.reactor.Reactor.dispatchChannel(Reactor.java:1958)

24 Mar 2021 08:26:21,523 ERROR [stderr] at com.thomsonreuters.upa.valueadd.reactor.ReactorChannel.dispatch(ReactorChannel.java:559)

24 Mar 2021 08:26:21,523 ERROR [stderr] at com.thomsonreuters.ema.access.OmmBaseImpl.rsslReactorDispatchLoop(OmmBaseImpl.java:1336)

24 Mar 2021 08:26:21,524 ERROR [stderr] at com.thomsonreuters.ema.access.OmmBaseImpl.run(OmmBaseImpl.java:1469).

24 Mar 2021 08:26:21,524 ERROR [stderr] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)

24 Mar 2021 08:26:21,525 ERROR [stderr] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)

24 Mar 2021 08:26:21,526 ERROR [stderr] at java.lang.Thread.run(Thread.java:748)

24 Mar 2021 08:26:21,529 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=EUGB1MBF=,rateType=39,label=EUR/GBP,contKey=24,tenor=1M,src_name=REFELSDK,delta=25,type=Butterfly/Put,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,532 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=EURGBP1Y=,rateType=7,label=EUR/GBP,contKey=24,tenor=12M,src_name=REFELSDK,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,536 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=JPYTN=,rateType=160,label=USD/JPY,contKey=2,tenor=Tom,src_name=REFELSDK,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,539 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent: .internalRegister(Ticker=EUGB1MRR=,rateType=39,label=EUR/GBP,contKey=24,tenor=1M,src_name=REFELSDK,delta=25,type=Reversal/Call,inverted=false,mutl_src=1.0) subscribed.

24 Mar 2021 08:26:21,542 INFO [JRefinitivAWSAgent] JRefinitivAWSAgent:



is anyone familiar with this error, any suggestions on how to fix this issue?

Thanks and regards,
Dumitru

elektronrefinitiv-realtimeelektron-sdkrrtema-apielektron-message-api
icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 5.0 MiB each and 10.0 MiB total.

3 Answers

Upvotes
Accepted
Gurpreet avatar image
13k ●32 ●12 ●18

Hi @dumitru.arama, I think there was a recent issue in which older version of EMA API was unable to download the dictionary from RRTO. Please have the client try this with latest version of EMA API.

+@zoya.farberov for visibility.

icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 5.0 MiB each and 10.0 MiB total.

Upvotes
zoya faberov avatar image
23k ●22 ●9 ●14

Hi @dumitru.arama,

I fully agree with @Gurpreet on retesting with the latest SDK.

I would like to also suggest, if the client then continues facing the issue with a custom RTTO consumer app, to retest with a standard EMA Java example 450, MarketPrice Discovery, included with SDK., enabling tracing on the example in EmaConfig.xml to try to better understand the issue:

<Consumer>
            <!-- Name is mandatory                                                                        -->
            <Name value="Consumer_1"/>

            <!-- Channel is optional: defaulted to "RSSL_SOCKET + localhost + 14002"                    -->
            <!-- Channel or ChannelSet may be specified                                    -->
            <Channel value="Channel_1"/>

            <!-- Dictionary is optional: defaulted to "ChannelDictionary"                                -->
            <Dictionary value="Dictionary_1"/>
            <XmlTraceToStdout value="1"/>
        </Consumer>

and share the output from the example.


icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 5.0 MiB each and 10.0 MiB total.

Upvotes
dumitru.arama avatar image
46 ●1 ●2 ●6

Thank you @Gurpreet and @zoya.farberov, will let the client know!

icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 5.0 MiB each and 10.0 MiB total.

Click below to post an Idea Post Idea