Hi there, We are currently using the ema library to collect news from refinitiv. We're connecting using ric: MRN_STORY group: 'com.refinitiv.ema', name: 'ema', version: '3.6.1.2' How is the recovery working? Let's say my listener is down for 2 hours, how do I get back the news that were disseminated during that time. Thank…
I have a EMA based data consumer (snapshot) application that sends batch requests (1000 instruments in each batch) to the managed elektron feed in EaaS data center... and in return , some of the requests return status of closed/suspect/timeout : 2022-09-02 13:30:41,302 [main] WARN : Request failed: service=IDN_RDF…
We are working with below EMA SDK: <dependency> <groupId>com.refinitiv.ema</groupId> <artifactId>ema</artifactId> <version>3.6.3.1</versio </dependency> These days we found some uncaught NulllPointerException in not .log file but standard output. Exception in thread "pool-25-thread-1" java.lang.NullPointerException at…
I use C++ version of EMA on Windows and CentOS 6.7 work fine. I am trying to use it on CentOS 7 but it always display error Exception Type='OmmInvalidUsageException', Text='Failed to add RsslChannel(s) to RsslReactor. Channel name(s) Channel_4 Instance Name Consumer_4_1 RsslReactor 0x0x2a34b70 RsslChannel 0 Error Id -1…
Client using EMA to connect LPC, and found LPC logout every 45 seconds, but code set sleep is 60 seconds. Could you please help review the code if any incorrect input? OmmConsumer ommConsumer = null; try { OmmConsumerConfig config = EmaFactory.createOmmConsumerConfig() .host("xxxx") .username("xxxx"); ommConsumer =…
For RTO EMA application, what's the compression approach used during message transferring? And configurations can be specified for the compression? The target is to minimize the data usage in the limited network bandwidth environment considering the possibility to leverage high compression ratio approach.
Hello everyone, can you please tell me exist possibility decrease delay between sended messages using Ema C++ interface. I using default approach with next code. And it's in the cycle without any delay from my side. consumer->submit(PostMsg() .streamId(_postStreamID) .postId(postID).domainType(MMT_MARKET_PRICE)…
So I have created a contrbutor based on the Consummer example code (which contributes prices despite its name ... is this correct?). The system connects corrrectly (a StatusMsg is sent and alogin request message is created and returned and that is acknowledged via a RefreshMsg) INFO: loggerMsg ClientName:…
Hi, please help me with this case. Scenario: Interactive Provider providing data to downstream consumers. For reasons external to the application, the Interactive Provider may not have yet the items requested by the consumers (e.g. in startup scenarios). If in this timeframe requests are received, they are replied with a…
Hi I am using Real-Time-SDK-2.0.6.L1, C++ EMA. Is using WarmStandbyChannelSet makes usage of ChannelSet redundant. What kind of additional resiliency I get by using both of these features ?
It looks like you're new here. Sign in or register to get started.
