-
Can "new" 64 Bit consumer consume "old" 32 Bit TREP data?
Hello, I am currently working on 64 Bit C++ Consumer using new LSEG 64 Bit SDK. We have old 32 Bit TREP backbone installed in our company. Can a new 64 Bit Consumer consume data from the old TREP? Or we need to install a 64 Bit backbone to utilize a 64 Bit Consumer? Thanks.
-
Consumer configuration for WarmStandby
Hello, We use RTC, which is connected to RTO, to retrieve quotes data. We are connecting to 2 instances of RTC with 2 instances of a client application using RTSDK Java, and we are wondering about setting up a resilient connection in all this by configuring multiple channels. Ideally, we'd like to configure all this via…
-
How to use Maven instead of Gradle to manage project directory?
In RTSDK Java, how do you use Maven instead of Gradle? For example: the Consumer class, as client wants to use Maven to manage the project directory.
-
Are there any ordering constraints on encoding/decoding different parts of an RSSL message?
I have an RSSL Consumer client using the Reuter's Domain Model. I also have an RSSL Producer server that is part of a testing harness to test my client. The consumer is successfully able to login, request and process source directory information, and request and process dictionary information, and I have tested this…
-
List of avaible servicenames
I am kind of new to EMA & ETA. I'm already config EMA Consumer to connect to ELEKTRON_DD. It works normally But I don't know what is ELEKTRON_DD service name and what data it provided. Is that real market data or dummy data? I want to get real market data for WYNN.BLUE symbol so what service name will provide that data.…
-
Hardcoded limits in ETA consumer example application
The ETA consumer example application has fixed limits for many of the items coming back in the RSSL messages. If for instance there are more services in the directory service response than the application can handle it simply errors. Or if a particular string length is larger than it is expecting it simply errors Are there…
-
EMA C++ - Print DataDictionary containing entries with negative ids
Hi all, using the Refinitiv EMA C++ library (3.6.1.L2), I'm seeing a weird behavior. The application is a consumer, downloading the DataDictionary from the network. The dictionary contains custom entries, which are using negative IDs. The consumer downloads and decodes the dictionary without issues: I can inspect and…
-
Error Text channel out of buffers errorId=-4 errorText=channel out of buffers
I am using the API version below to submit 7800 messages. This worked fine for months but is suddenly giving me the error below. API Version <groupId>com.thomsonreuters.ema</groupId> <artifactId>ema</artifactId> <version>3.2.0.2</version> Error ClientName: SingleItem Severity: Error Text: Internal error:…
-
Questions about EMA FID
Hi, I have two questions: 1.EMA Cons113 ,the fid 3855 FieldEntry fid="3855" name="QUOTIM_MS" dataType="UInt" value="45259368" how to convert it to normal form of time like "hhmmss" 2. Which fid is for "trade day", is fid 875 okay for that? Thanks
-
Unable to connect to RCC channel using EMA Consumer
1. Using EMA as gradle dependency implementation group: 'com.refinitiv.ema', name: 'ema', version: '3.6.6.0' Java 17, Windows 10 2. I used example from https://developers.refinitiv.com/en/api-catalog/refinitiv-real-time-opnsrc/rt-sdk-java/tutorials#ema-consumer-posting-data-to-contribution-channel Stuck on Establish an…
-
Ema Cons113 dictionary retrieval failed
When debugging the code, the following error was reported. Why? Exception Type='OmmInvalidUsageException', Text='dictionary retrieval failed (timed out after waiting 45000 milliseconds) for :) ', ErrorCode='-4055'
-
EMA Java Status messages "Slow Consumer" and "Data was lost for this security". Cannot repeat.
Hi - I am trying to recreate a slow RMDS consumer scenario we have seen using EMA Java 3.6.0. I can repeat all the channel and ticker status messages, but in one instance we saw this status message: Received status msg: text:Slow Consumer, statusCode:None, data:Ok, stream:Open do you recognize this message. When would we…
-
EMA:Call to rsslReactorDispatchLoop() failed. The _state is set to OmmImplState.NOT_INITIALIZED
loggerMsg ClientName: EmaConsumer_9 Severity: Error Text: Call to rsslReactorDispatchLoop() failed. The _state is set to OmmImplState.NOT_INITIALIZED loggerMsgEnd This error occurs when I call OmmConsumer's uninitialize() one:Why does this happen? two:How do I catch this exception error? three:How to handle this error?…
-
VAConsumer application curl issue
Hi. I'm updating our VA Consumer application to connect to RTO. I'm following the example VAConsumer code in the RTSDK - here. I can run the RTSDK VAConsumer example and connect and get data so I know I have connectivity and the right credentials etc. But my application keeps failing with this log Failed to request…
-
EMA C++ can not pass a OmmArray to OmmConsumerClient
I create a class who inherited the OmmConsumerClient, and I pass a OmmArray to the construction function in order to decode the fids that I want RefinitivClient::RefinitivClient(const OmmArray & fids) : m_fids(fids) { } void RefinitivClient::decode(const refinitiv::ema::access::FieldList & fl) { ElementList search;…
-
Consumer application (java) ERT Cloud / Refinitiv Real-Time Optimized
Hello Developer and API Support, I have already build consumer and publishing application in java using Elektron API and WebSocket as well RCC for contribution via the public Internet or RTDS connections. I want now try to build a consumer app which receive prices from Refinitiv ERT Cloud or Refinitiv Real-Time Optimized,…
-
Unknown Msg class and Random Symbols received post subscription
After subscribing to Market Data over the ELEKTRON_DD feed , we notice that we receive Unknown Msg class errors and random symbols which we are unable to interpret. Could you please help understand what could be causing this? Received STATUS message for key - null, streamId - 1348. TREP response: Processed 91 total items…
-
Problem with consumer application
After creating a client id using the app key generator... i get this error msg any ideas? thanks Thread 1 "FX_MktDataClien" received signal SIGINT, Interrupt. 0x00000034f74df5b7 in ppoll () from /lib64/libc.so.6 (gdb) Continuing. loggerMsg TimeStamp: 09:08:18.305 ClientName: ChannelCallbackClient Severity: Warning Text:…
-
The relationship between consumer channels and consumer events
We use OmmConsumer with ChannelSet. How do we know which channel the event in OmmConsumerClient::onStatusMsg belongs to, or what other ways to receive events in conjunction with the channel they belong to? In addition, the registered OmmConsumerClient does not receive the first successful connection event. So again it is…
-
EMA OmmConsumer memory leak in C++ API?
We need to switch between hosts in case of unavailability. To do this, we recreate OmmConsumer with new settings (only one OmmConsumer exists at a time). If all hosts are unavailable, the memory leaks out exponentially during 30 attempts, which leads to the process crash. It is empirically established that the memory leak…
-
Conflated mechanism advantage
What is it the real advantage to have ConflatedInUpdates set to true. As I can see this parameter is set to false as default. In which cases could be useful change the default value?
-
Symbol List Request and Refresh Messages
In documentation of RDM Usage Guide I can read this: In particular the sentence: A Symbol List refresh can be sent in multiple parts. Update and status messages can be delivered between parts of a refresh message, regardless of streaming or non-streaming request. However, above in the point 11.2.1 I can read this: In…
-
[EMA C++] DoNotCache and ClearCache in RefreshMessage from the point of view of Consumer Application
What is it the right behaviour from the point of view of a Consumer Application that receive refreshMessages and read parameter DoNotCache and ClearCache. Which action a Consumer Application need to do in those cases?
-
RFA C++ consumer application dis not reconenct to ADS
A RFA consumer application receives an OMM Connection event with the following details: ConnectionName:'Connection_RSSL' Host:206.100.1.240, Port:14002, ComponentVersion:'ads3.2.2.L1.linux.tis.rrg 64-bit', State:Up(1), StatusCode:None(1), StatusText:'Connection up' Shortly after a login response with the following details…
-
[EMA Java] How to retrieve the client id in OmmConsumerClient.onStatusMsg
the method OmmConsumer.registerClient returns a long value (id) that can be used later to unregister, etc. Can this value be retrieved from either the statusMessage or event received in OmmConsumerClient.onStatusMsg(StatusMsg msg, OmmConsumerEvent event) ?
-
How to monitor ETA consumer performance
Hi, When the ETA client does not consume data quickly enough and the output buffer fills up, the provider (ADS) simply disconnect the client without warning. Is there a way for the consumer to verify if it's consuming data quickly enough ? For instance, is it possible to check the usage of the input buffer ? Thank you
-
EMA Java - idle consumer disconnecting
As a temporary workaround for issue mentioned here https://community.developers.refinitiv.com/questions/28182/ema-ommconsumer-memory-leak-in-java-api.html we implemented a pool of consumers. It works, but now we faced another issue: When the consumer sits idle in the pool it eventually disconnects from Reuters and when we…
-
EMA OmmConsumer memory leak in Java API?
In our application we often need to do ad-hoc snapshot data queries. For that we create OmmConsumerConfig, read dictionary file (from local filesystem), pass config to w newly created OmmConsumer, then use consumer to subscribe for data, collect it, then unregister the handler. Finally we uninitialize() the consumer and…
-
Read Resource file "RDMFieldDictionary" have some problem
In this method QSConsumer.java public void init() { String fieldDictionaryFilename = "../etc/RDM/RDMFieldDictionary"; String enumDictionaryFilename = "../etc/RDM/enumtype.def"; try { GenericOMMParser.initializeDictionary(fieldDictionaryFilename, enumDictionaryFilename); } catch (DictionaryException ex) {…
-
Using one consumer-client for two RICs?
Hi, We are currently in the test phase of consuming data in the News Text Analytics domain. And we consume two contents, MRN_STORY and MRN_TRNA. Currently we have two services receiving each content separately and then joining them afterwards. 1…
-
Multiple DACSId/LoginIds using same rfa Session for Consumer Application...
Do we need to create multiple session for different Login / DacsIds in one consumer application? Can a session be shared by different DACSIds? What are the implications of sharing the session?
-
How to use single session supporting multiple users for remote authentication in SSL RFA Java Subscr
My application works as a proxy for different users which are connecting to it to get data from TREP(ADS/ADH). I would like to use Remote authentication that entitlements are done in TREP site. I have found in RFA Java Developer Guide that -“For remote environments, the application must supply the Tokenized Principal…
-
What's the differrence between EMAJ consumer and ETAJ consumer?
I supposed that EMAJ is a better version to use, it includes some part of the ETAJ. But I don't find the heartbeat part, in ETAJ doc , channel.ping(error) method can send the ping, but how to do in EMAJ consummer? Please help me, because it's urgent.
-
How can we apply a filter in quick consumer application in RFA.net to get only Ask/Bid Prices.
Sample code: FieldList fieldList = payload as FieldList; ///Console.WriteLine("FieldList's entry count: " + fieldList.StandardDataCount); short fieldId; foreach (FieldEntry fieldEntry in fieldList) { fieldId = fieldEntry.FieldID; try { RDMFidDef fidDef = rdmFieldDictionary.GetFidDef(fieldId); } moragodkrit
-
Do you have an example on how to use : " rtmesBuffer" ? RMTES Decoder EMA provides a built in R
Do you have an example on how to use : " rtmesBuffer" ? RMTES Decoder EMA provides a built in RMTES decoder. If desired, application may cache RmtesBuffer objects and apply all the received changes to them
-
How do I know when the dictionary refresh is complete?
When requesting a dictionary I can't tell when I've received all the messages. Currently I get 4 refresh messages with the field dictionary spread accross them. How can I tell in Elektron that I have no more messages pending? In RFA you can set completion events or check the connection state but I can't find the equivalent…
-
Subscribing to RIC multiple times
I have a subscription to a set of RICs (e.g. VOD.L) open which processes deltas and populates a cache Another operation we want to support is the ability to do an AdHoc market data request for a RIC to get a snapshot in time. If I request VOD.L for an AdHoc snapshot, while our cache service is running (processing changes…
-
Why does OMM provider logs "RSSL Channel read failed on connection" when OMM consumer shuts down?
When shutting down our OMM consumer with our OMM provider, the OMM provider logs an error " RSSL Channel read failed on connection" even if - I hope - the consume cleans up properly. Any idea what the consumer may miss on clean up?
-
Explain "Channel flush failed" error
In RFA configuration for RSSL consumer connections, we set the parameter "serverList" with the following ADSs: "server74", "server75", "server76", "server09", "server10". During an recovery training, the 3 first ADSs have been separated from the network so that they can not be reached by our RFA clients. During our…
-
Limit Exceeded Issue in EMA Consumer application - News and market data
Hello , I am getting the below Item state on refresh message while subscribing for PNAC of a News Closed / Suspect / Too many items / 'A20: Aggregate item limit exceeded ' . I understand that I have subscribed to too many PNAC's , i would like to understand few more things . 1 . Is there a limitation on subscriptions per…