-
RTO EMA Java SDK. Timeout.
During integration with the RTO EMA Java SDK 3.9.0.1, we have faced a timeout exception: com.refinitiv.ema.access.OmmInvalidUsageExceptionImpl: login failed (timed out after waiting 45000 milliseconds) for us-east-1-aws-3-sm.optimized-pricing-api.refinitiv.net:14002) at…
-
Ema - no payload for batch requests in IProvider
Hello, I am using EMA Refinitiv version 3.8.3.0 and I have implemented a consumer based on example ex370_MP_Batch. I have also created a stub component based on Provider example 102_MP_Snapshot. Consumer communicates correctly with the provider, however provider does not receive the payload for batch request. My use case…
-
EMA Java Creating multiple OmmConsumer instances problem
Hello all, I am using the EMA Java library group: "com.refinitiv.ema", name: "ema", version: "3.9.0.1" I am trying to create multiple connections to the HMDS websocket at the same time, on multiple threads, but I ran into a problem. After creating the OmmConsumerConfig for each connection that I will have to make and then…
-
C# EMA Interactive Provider High memory consumption
I m trying to build a Net core intercative provider using EMA, all works fine and i m able to respond to incoming requests, however, the process memory is nearly 1Gb after launching the application, I tried to reduce the : ItemCountHint : 200 But memory is still high nearly 670Mb, without any request. Well I tried to do…
-
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();…
-
Disable Refinitiv Contribution Channel (RCC) for an EMA API user
Hi team Is there any option to disable an EMA API user to contribute to RCC , but allowing to get RICs as a consumer ? Mant thanks Odon
-
Springboot REST API using EMA
was looking for examples of how to develop a springboot REST API using the EMA API. Any good references ? using the following version implementation("com.refinitiv.ema:ema:3.8.3.0")
-
Deadlock at OMMConsumer
There is deadlock at OMMConsumer while un-registering ric. Please advise. Below are logs from application. at sun.misc.Unsafe.park(Native Method) at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) at…
-
A46: Item was reopened under new stream.
Hi Team, One of my client faced this issue "A46: Item was reopened under new stream." recently. As you mentioned in link “A46: Item was reopened under new stream.” — LSEG Developer Community , the client may have duplicate subscription in the batch request message(s) and closed the first stream. Why there is no data update…
-
which fields can use "partial updates"
Hello. Is there a way to know in advance, whether a RMTES_STRING field in an incoming EMA message may contain a partial update ? E.g. the fields 215 ("ROW64_1"), ..., 228 ("ROW64_14") are such fields. I don't want to scan every field for partial updates.
-
“#N/A Item request rejected: Item already opened with another stream
Hi team, Client discovered with this sample CHFOIS12Y RIC that gave the following error "“#N/A Item request rejected: Item already opened with another stream (stream id = 10333, item name = CHFOIS12Y, domain = RSSL_DMT_MARKET_PRICE(6))”. Every time it was for their internal source hosted on 2 active ATS server (source name…
-
Can testserver playback recording in a loop?
Hi, I am using testserver from the docker image refinitivrealtime/infratools:3.8.1.L1 and I am Running the playback from a XML file that I have captured using the test client. Using the following command: testserver-S DIRECT_FEED -Q dist/recXml.xml -U 1 -N 14002 -K -ik -t 361 It looks like the testserver finishes and no…
-
EMA stops retrieving updates after couple of hours
I subscribe to 10K RICS. My application was running OK and now after couple of hours every day it is just stop retrieving the updates. I do it via multithreading, having 3 consumers and no error/logs are shown. Any idea what could go wrong?
-
Does consumer need unregister all instruments before consumer.uninitialize()
As far as I know, for any unsuccessful item subscription, the application will receive a Status message with OmmState.StreamState.CLOSED and OmmState.DataState.SUSPECT via onStatusMsg(..). When the application receives a StatusMsg with Stream.Close / Data.Suspect after calling consumer.uninitialize(), but not if…
-
C++ NIProvider publishing to ADH service does not work
I am testing according to lseg C++ NIProvider tutorial.I am testing on internal service “DTS_KL” of internal ric “USDFON=MBBGM”, the codes are like the following.OmmProvider. provider(OmmNiProviderConfig("c:\\temp\\process\\x64\\EMAConfig.xml").username("drdwhw")); UInt64 serviceId = 1000; UInt64 sourceDirectoryHandle = 1;…
