-
How to get the SeriveName in Provider from consumer, during application shutdown at consumer
we are having a provider(RFA), and a Consumer(Ema). When subscribing to the MarketDataService from the Consumer, the ServiceName appears on the Provider side through Trep. However, during application shutdown on the Consumer side, automatic unsubscription calls are made, which we observe at the Provider end. Unfortunately,…
-
RTSDK EMA C++ -not able to set serviceName and see it right away
For my unit tests I need to set name and serviceName to my message. I need to create a message and then pass it to my OmmConsumerClient class. But it did not work. After multiple attempts to make my code work, I finally realised that the issue is in particular logic of setting serviceName. When setting serviceName message,…
-
C++ API Dictionary programmatic setup
Greetings! I am using latest RTSDK C/CPP 2.1.3.G1 aka EMA/ETA 3.7.3.G1 aka 3.7.3.3 and having dictionary timeout issues similar to https://community.developers.refinitiv.com/questions/95787/emadictionary-retrieval-failed-timed-out-after-wai.html I increased timeout up to 120 seconds, and it helped only once, while most of…
-
OmmInvalidUsageException due to timeout in application
Hello, We are tring to connect to RTO with our application created using the EMA libtrary part of Real-Time-SDK-2.1.3.E1.linux.zip package. EmaConfig.xml file: <Name value="Channel_1"/> <!-- ChannelType possible values are: --> <!-- ChannelType::RSSL_SOCKET - TCP IP connection type --> <!-- ChannelType::RSSL_HTTP - Http…
-
How to handle COMPLETION_EVENT while migrating Refinitiv RFA API to EMA API?
We are currently upgrading our application from RFA API to use EMA API. We referred a similar question in this link: https://community.developers.refinitiv.com/questions/92298/whats-the-equivalent-of-rfas-completion-event-in-r.html But we are not able to use the rsslIsFinalState given in the solution here. Please provide a…
-
What type of durability EMA has?
Hi All, We subscribed for financial market data through a batch request to EMA. What happens when the update message is ready but the consumer is busy with another API call to consume some other data? When I ask this query, consider I didn't mean disconnection between the Refintiv and EMA. Does Refinitiv internally follow…
-
C++ EMA Horizontal Scaling Limitations / Connection Lost
Hello, we are experiencing a similar situation as the one mentioned on this thread https://community.developers.refinitiv.com/questions/43780/an-established-connection-was-aborted-by-the-softw.html. We have attempted horizontal scaling, as shown in this example…
-
Is there a way to request all symbols for Market Price request?
Hello, Based on my understanding of UPA RDM, it seems that if I want to request market price updates for a set of symbols, I need to either send a request per symbol, or send a batch request, where in either case I have to enumerate every symbol via RDM_INSTRUMENT_NAME_TYPE_RIC. Is there a way I can instead make this…
-
Getting out of buffer exception due to slow consumer (EMA C++ OMM API)
I'm building a interactive provider (EMA C++ OMM API) for streaming the market data to different downstream applications, which are Refinitiv Consumer, through TCP socket. I'm testing the scenario that how my provider behaves when I have very slow consumer connect to it. I found that the provider will throw an out of…
-
How do we perform a right shutdown on my EMA customer ? OmmConsumer.unregister() needed or not ?
How do we perform a right shutdown on our EMA customer ? * When we shutdown our EMA Customer process, do we need to use OmmConsumer.unregister() method on every stream handle that we have registered ? * Or the call to the method OmmConsumer.uninitialize() will release automatically all stream handles at both Customer and…
-
unregister() causes internal stack trace
I have written the simplest code example that returns a refresh message and it gets a internal stack trace on unregister(). What's wrong in these 40 lines? OnMsgTest onMsgTest = new OnMsgTest(ommConsumer, symbol);<br /> long handle = ommConsumer.registerClient(reqMsg.serviceName(source).name(symbol), onMsgTest); and later…
-
Potential deadlock with OmmConsumer
We are creating an EMA consumer, and then opening item streams (100 items batched in each ReqMsg) with the consumer. We simply stop seeing new messages a few minutes after the consumer is established, without any exceptions or errors. This happens while the loop of opening item streams is ongoing. Debugging shows that…
-
How to make OmmConsumerClient recover from Open / Suspect / None state
hey, I consume RICs from TREP using this way: ReqMsg reqMsg = EmaFactory.createReqMsg().serviceName(serviceName).name(ric); long streamId = consumer.registerClient(reqMsg, new Client(...)); class Client implements OmmConsumerClient { @Override public void onRefreshMsg(RefreshMsg msg, OmmConsumerEvent consumerEvent) { // do…
-
Only certain RIC codes are not received. (ex) /.INX, /GCc2
Hello. I've been having problems with my system since this week. Only certain RIC codes are not received. (ex) /.INX, /GCc2 All other US stocks, indices, futures, etc. are received normally. The code to register is as follows. // OmmConsumer consumer // ReqMsg reqMsg = EmaFactory.createReqMsg(); // String serviceName =…
-
How reduce delay between sending messages using Ema C++ Consumer
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)…
-
OmmConsumer token refresh using Java SDK
Client's query: I understand that you use Oauth and how that works. But we are using your Java SDK and use a OmmConsumer. As I understand it the OmmConsumer should handle that. And I find no documentation on how to make a OmmConsumer refresh it’s login. So my actual question is how do we keep our OmmConsumer fresh. Do we…
-
EMA C++ OmmConsumer memory consumption
Hi guys, For some reason, I need to create multiple OmmConsumer instances. I can see one instance takes about 180MB. Is there a way (via configuration) to have this number smaller? I am currently using version 2.3.0. I looked into docs but it seems like the default values are already small. So not sure if there is anything…
-
OmmConsumerClient Registration Count Recommendation
Within a consumer application, should a single OmmConsumerClient instance be used to handle all OmmConsumer::registerClient() for every single item the application will register for? Or is there a recommendation to split this up to multiple instances of OmmConsumerClient?
-
OmmConsumerClient onUpdateMsg only updated fields
When updating a specific record field for a RIC, it seems all the fields for the records are sent into onUpdateMsg. Is it possible to only get the updated fields in the callback?
-
Pause/resume and decreasing the frequency of updates coming from an ADS.
Hi, I have an ommConsumer that registers its interests and receives updates from the server. Sometimes the rate of updates is too high and I would like to either pause/resume or decrease the update rate. Is it possible at all? I am using Java and would be useful to see an example/code-snippet in case it would really be…
-
Rolling event log files per day using Ema C++ SDK
Hello everyone, can you please tell me exist possibility write log files each day if application work whole time. Expected result that's EMA create new log file each day without restrictrions for time application working.
-
Have any method to get fields number by fields names before request?
When I use StarterConsumer_BatchView C# sample, have any method to get fields number by fields names before request not from reponse data. Because via RFA.NET api to request data has to send fid id not fid name,so have any method can get fid id by fid names.
-
OMM Consumer Config encryption query
Hi, Thanks if you can guide for below. When using the following connection method from the OmmConsumerConfig interface, is the traffic encrypted? OmmConsumerConfig config = EmaFactory.createOmmConsumerConfig(); config = EmaFactory.createOmmConsumer(config.host(“ip:port”).username(“username”)); * If not, can you please…
-
OmmInvalidHandleExceptionImpl invalid handle exception
SEVERE: [{"incidentClass":"Uncaught OmmInvalidHandleExceptionImpl in DataPublisher","details":{"pool":"Publisher…
-
Decoded login message has wrong OMMMsg.MsgType
I'm using a RFA Java client to log into a Interactive provider. On the login request message I send, I explicitly set the message type to REQUEST (4) : msg.setMsgType(OMMMsg.MsgType.REQUEST); However, when the message arrives at the provider, after the message is decoded back into OMM from RWF, the message type has…