-
Best way to determine connection status of Real-Time SDK Application
We have a Real-Time SDK application that has the following: class ConsumerClient : public access::OmmConsumerClient { public: ConsumerClient(…) { … } protected: void onRefreshMsg(const access::RefreshMsg &msg, const access::OmmConsumerEvent &event) { processState(msg.getState()); } void onUpdateMsg(const access::UpdateMsg…
-
Directory domain with warm standby
Hi. question regarding RTSDK example 470_MP_WarmStandby. I am subscribing to Directory domain stream to get service statuses. with ChannelSet failover when after registering to dictionary domain, I can see refresh as expected. when using WarmStandby mode onRefreshMeg handler in client is not called (Login and dictionary…
-
How can I pull real time data on the Python API for LSEG
I am trying to pull real time data for some RICS listed below, however I find that Equity Inidicies show up as blanks with NULLS across. What can I do to pull the latest SPX Value? rics = [ '.SSEA', '.GDAXI', '.DJI', '.STOXX50E', '.FTSE', '.HSI', '.NIFTY500', '.N225', '.MXX', '.IXIC', '0#.SPX', ".INX", '0#.GSPTSE',…
-
I have implemented the Service Discovery feature as mentioned in the example Cons450 example but sti
Inquiry Service discovery is only to select service dynamically at runtime (MS startup only) but it is not supporting services resiliency after that, so if the service "us-east-1" is selected at the MS startup then it went down, it will not change automatically to any other service. Service Discovery Implementation I…
-
Preferred Host with Warm Standby Group ServiceBased mode EMA consumer
Hi. How can I configure EMA consumer with multiple WSBGroups for serviceBased failover? My goal. have 2 WSB groups 2 channels each. if Ema receives SErviceDown from Group1ActiveServer it switches to Group1StandbyServer. if service on Group1StandbyServer is down EMA switches to Group2ActiveServer and so on. Bonus Failback…
-
How to measure the RTO latency via EMA
Do we have the time related metadata or fields in the message/event of the onRefreshMsg and onUpdateMsg methods, to measure the RTO emit/ingestion/pipeline latency? Or other similar mechanism? Not the QUOTIM and TRD_TIME.
-
Beginner Guidance for LSEG SDK APIs, RTDS, and Refinitiv Workspace (Java)
Hi Community, I’m a beginner and aiming to become proficient in LSEG SDK APIs, RTDS (Real-Time Distribution System), and Refinitiv Workspace. I’ve chosen Java as my programming language and would appreciate guidance on the following: Where should I start as a complete beginner? Any recommended learning path or sequence for…
-
How to Contribute to Refinitiv Page / Row
I have previously worked with the Bloomberg API and am now trying to also use the Refinitiv API to contribute some text to a particular page and row in Refinitiv. Does anyone have a general guideline on how to get started. I am confused on whether I should be looking at the RTSDK ETA/EMA API's as it seems to be desktop…
-
Assertion when trying to connect to RTOv2
Hello, I'm working on connecting my Java application to RTOv2. To do so, I use the RealTime SDK 3.8.3.0 I had to fight a little bit but now my application starts working fine 👍️ However, I realized that when the JVM option -ea (enable assertions) is enabled, my application crashes on the following method of the Realtime…
-
Need support for connecting to RTO v2
Hi, I have to update the code of a software so that it supports RTO v2 (previously it was supporting RTO v1) In RTO v1, I used to connect thanks to the following code: private OmmConsumer createOmmConsumer() { OmmConsumerConfig ommConsumerConfig = EmaFactory.createOmmConsumerConfig(configuration.getConfigurationFile());…
-
SDK Compatibility with CMake Version > 4.0
Hello, I'm facing some issues compiling the SDK with cmake version > 4.0. I’ve observed that CMake 4.0 drops support for CMakeLists.txt file with version older than 3.5, which appears to be required by the l8w8jwt library (a dependency of the SDK). Could you please confirm which SDK version supports CMake version > 4.0?…
-
Need to publishing multiple Rics in Parallel to avoid performance issues
Currently when trying to publishing 10000 Rics one by one so it is taking almost 40-45 mins to publish but need to publish the records in few mins with Parallel publishing if possible from the number of set to be publised at a time. I am using the NiProvider. TrepPublishingClient appClient = new TrepPublishingClient();…
-
TREP: Unexpected "Output threshold breached for <user>...."
Hi, I developed a JAVA application based on Refinitiv Realtime SDK, that is consuming RICs on TREP. Today, one of my customer reporting an issue that he was able to observe many time during the night: my application is disconnected from TREP ADS logs shows errors such as Output threshold breached for XXX" at position…
-
PAR Spread/I-Spread calculation
based on https://github.com/Refinitiv/Real-Time-SDK/blob/master/Java/etc/RDMFieldDictionary what field should I use to calculate PAR Spread/I-Spread for bonds
-
Tokyo Stock Exchange Special Quotes
Hello, I would like to know how to identify a message for Tokyo Stock Exchange special quote messages and the special quote price. What update message type and key value and fields will I need to look for in order to know?
