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
Best Answer
-
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.
0
Answers
-
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.
0 -
Thank you @Gurpreet and @zoya.farberov, will let the client know!
0
Categories
- All Categories
- 6 AHS
- 37 Alpha
- 161 App Studio
- 4 Block Chain
- 4 Bot Platform
- 16 Connected Risk APIs
- 47 Data Fusion
- 30 Data Model Discovery
- 608 Datastream
- 1.3K DSS
- 577 Eikon COM
- 4.9K Eikon Data APIs
- 7 Electronic Trading
- Generic FIX
- 7 Local Bank Node API
- Trading API
- 2.7K Elektron
- 1.3K EMA
- 236 ETA
- 519 WebSocket API
- 33 FX Venues
- 10 FX Market Data
- 1 FX Post Trade
- 1 FX Trading - Matching
- 12 FX Trading – RFQ Maker
- 5 Intelligent Tagging
- 2 Legal One
- 20 Messenger Bot
- 2 Messenger Side by Side
- 9 ONESOURCE
- 7 Indirect Tax
- 59 Open Calais
- 264 Open PermID
- 39 Entity Search
- 2 Org ID
- PAM
- PAM - Logging
- 8.4K Private Comments
- 6 Product Insight
- Project Tracking
- ProView
- ProView Internal
- 20 RDMS
- 1.4K Refinitiv Data Platform
- 367 Refinitiv Data Platform Libraries
- 3 Refinitiv Due Diligence
- LSEG Due Diligence Portal API
- 3 Refinitiv Due Dilligence Centre
- Rose's Space
- 1.1K Screening
- 18 Qual-ID API
- 13 Screening Deployed
- 23 Screening Online
- 10 World-Check Customer Risk Screener
- 990 World-Check One
- 44 World-Check One Zero Footprint
- 45 Side by Side Integration API
- Test Space
- 3 Thomson One Smart
- 1.2K TR Internal
- Global Hackathon 2015
- 2 Specialists Who Code
- 10 TR Knowledge Graph
- 150 Transactions
- 142 REDI API
- 1.7K TREP APIs
- 4 CAT
- 21 DACS Station
- 117 Open DACS
- 1.1K RFA
- 103 UPA
- 172 TREP Infrastructure
- 224 TRKD
- 886 TRTH
- 5 Velocity Analytics
- 5 Wealth Management Web Services
- 59 Workspace SDK
- 9 Element Framework
- 5 Grid
- 13 World-Check Data File
- Yield Book Analytics
- 46 中文论坛