-
OmmProvider to flag expired RICs or temporary issues with existing RICs.
Hi, I need help on how to publish messages that a RIC has either expired or it is currently stale/temporary issue over your Transport API. Something like below by example: domain:MarketPrice streamstate:Closed datastate:Suspect statuscode:NotFound statustext:**The record could not be found Kind regards, Johan
-
OMMMsg的getDataType、getMsgType不同值的含义
OMMMsg的getDataType=132、getMsgType=6和getDataType=132、getMsgType=8有什么区别?
-
Encoding String into OMM Type in RTSDK-Java (EMA)
I'm encoding my payload into a OMM Message. The old RFA had a utility function in the `OMMEncoder` class, where one could pass a value as `String` and an `OMMType`: String fvalue = field.getValue(); FidDef fidDef = fieldDict.getFidDef(fname); encoder.encodeString(fvalue, fidDef.getOMMType()); The encoder encoded the string…
-
Unhandled Exception: ThomsonReuters.RFA.Common.InvalidUsageException for OMMConsumer::UnregisterClie
We are facing occasional crash in process using RFA API. and log says: terminate called after throwing an instance of 'rfa::common::InvalidUsageExceptionImpl' From https://community.developers.refinitiv.com/questions/25948/unhandled-exception-thomsonreutersrfacommoninvalid.html I understood the way to get extra information…
-
PUB_ERROR_EVENT vs OMM_CMD_ERROR_EVENT
Hi, I'm using the RFA Provider to publish data into TREP At some point we stop sending some data and have a listener registered with the OMM_CMD_ERROR_EVENT Please can someone explain the difference between OMM_CMD_ERROR_EVENT and PUB_ERROR_EVENT? Do we need both to detect loss of data that we were attempting to publish?…
-
"Failed to open OMM stream" while trying to query RIC
Hi, I'm trying to do a simple query of a given RIC (USOILC=ECI) using the C# WebSocket API. Unfortunately, every time I try and open a stream for the RIC, I end up with this error: Stream error: 1/31/2023 8:43:47 AM: => { "Error": "Failed to open OMM stream - streaming services are unavailable. Verify log details and…
-
About OMM Viewer
Hi, Right now we are using OMM Viewer for querying LPC server. Is OMM Viewer going to be over by end of this year? What is an alternative?
-
Do We need to handle rfa::message::RespMsg::ClearCacheFlag in LL2 MBP domain?
We are using RFA 8.1 C++ API to consume depth data using LL2 MBP (MP domain). Do We need to handle rfa::message::RespMsg::ClearCacheFlag in LL2 MBP domain? It is marked as optional in documentation [RDMUsageGuide]. But we are facing some issue with the levels we receive, we doubt that we are not handling some instruction…
-
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…
-
Failure on OMM stream: Malformed JSON received during token refresh: '{"error":"server_error" ,"err
Hi Community members. I really appreciate your support, sorry if this question is to direct, I wish to clarify I don't actually know if it is a bug on Refinitiv Server Backend side, just searching for solution. Seems like there is an error on Refinitiv server related to the session refresh token process of OMM websocket…
-
continuing question 97398 ommstreaming-pricing-012-received-a-closing-messag (I cant add a comment t
Hi Wasin.w I took your recommendation and upgraded to 1.0.0b20, Error call-back is not launched when stream halt. on my code self.current_rd_session = rd.open_session() self.theWebSocket = rd.content.pricing.Definition([ 'HTEc...,'CHFUSD=R'], fields=['BID', 'ASK', 'QUOTIM', 'QUOTIM_MS',....]).get_stream()…
-
Getting add entry for already existing levels. Getting update entry for non existing levels.
Hi, We are using RFA 8.1 API's with MarketByPrice domain. This is in regards with level 2 data. We received an add entry for an order id that already exists in our local book. Symbol : APPS.MC Timestamp : 20220907-06:30:17 EST Order Id : 6.6350B Similarly an update entry was received for an order ID that was not present in…
-
RFA 8.2.0L2 C++ Crash on field decoding using outdated field dictionary
Hi, I need some help on a crash we have with RFA Lib in C++ on Linux. We use version 8.2.0L2 of the RFA Libraries to subscribe to OMM feed. We know the reason of the crash; the dictionary of data was outdated (yes it's bad), and a field type was wrong. In the outdated dictionary the field was defined as REAL64 but it…
-
Continuing question 93989 ommstreaming-pricing-012-received-a-closing-messag (I cant add a comment t
hi Jirapongse I asked a question in the past "[OMMSTREAMING_PRICING_0.12] received a closing message (cxn state=StreamCxnState.Connected, message state={'Stream': 'Closed', 'Data': 'Suspect', 'Code': 'UserAccessToAppDenied', 'Text': 'TREP authentication failed (1026, Request for token validatio" Jirapongse sent me an…
-
Not able to receive level2 data for RIC AEV.PS using MP domain
Hello, I am using Refinitiv real time data feed (TREP) to consume level2 market data using C++ api. I tried to request level2 data for RIC AEV.PS using "MP" domain but did not receive any data.. May I know why I am not receiving the data?
-
ClearCacheFlag and RefreshCompleteFlag in Unsolicited Refresh message
Hello, I am using RFA 8.1 API's with MarketByPrice domain. I few doubts about ClearCacheFlag and RefreshCompleteFlag 1. If I want to know indication mask in Refresh message, should I use RespMsg::getIndicationMask or Map::getIndicationFlag? 2. What is the correct order of receiving Clear cache and Refresh complete? When I…
-
Force Logout from DACS reasoning needed
See below logs, and client would like to speak to a dev on why this is happening @timestamp,@message 2022-07-23 05:14:28.362,"<ads-fanout-med-az1-use1-prd.1.ads: Info: Sat Jul 23 05:14:26.885881 2022> RSSL login close for ""GE-3785"" at position ""127.0.0.1/ld4macp1p1co1"" on host ""ld4macp1p1co1"" using application…
-
[900]: Service Denied. RIC creation using ATS_INSERT_S
Hi, Im trying to write java program using EMA API to create RIC record on ATS. I have been following all the steps as documented here : Implementing Refinitiv Real-Time APIs applications to work with ATS - Part 1 | Refinitiv Developers But still got ack that says [900]: Service Denied. Referring to refinitiv documentation,…
-
How to find out if the case is ongoing?
Which API to use to find out if ongoing is already enabled for a specific case?
-
OMM L2 start of trading day
We have a binary using RFA C++ 8.2.1.L1. We use OMM L2 to get L2 data. Our client subscribe during the morning to L2 data and everything is fine. We get a stream of L2 data. On the next day, during opening we still have order book from previous day present. How can we know it's a new day and order book has to be cleared ?
-
TRCC: "Max message rate breached" in StatusMsg, connection closed.
I have an app that uses an OmmConsumer object to submit PostMsg's to the TRCC. Until recently it was coded to send one RIC, wait for the onAckMsg message to fire, then sent the next one, and so on. I noticed that one particularly big collection (>1700 RICs) was taking 7-8 minutes to complete so I decided to change the loop…
-
Difference between RefreshMsg and StatusMsg
In our application, we got only RefreshMsg as below at a certain time. Refresh message (unspecified type), stream open, data suspect, status code None After that we started to receive StatusMsg as below. Status message, stream closed, data suspect, status code NotFound What are the difference between RefreshMsg and…
-
EMA Channel failover
Hello, I have a EMA Consumer based application. I am using a ChannelSet with two channels (two different IP addresses). However, when the first channel in the ChannelSet goes down (I get a 'ChannelDownReconnecting event on channel Channel_1' message, and 'Channel is down', etc), my subscriptions do not automatically…
-
Is there a way i can utilise rmdstestclient / rmdstestserver to simulate OMM off-stream post via an
Is there a way i can utilise rmdstestclient / rmdstestserver to simulate OMM off-stream post via an ads to a non-interactive source on a ADH?
-
OMM viewer cannot connect to LPC
i have installed LPC 1.2.0.L1 , with the testclient command i can get data as shown below. ./testclient -S ELEKTRON_DD -p 14002 -X -d3 -m -v rssl -u user01 -h 192.168.2.9 -itemList EUR= installed OMM Viewer 8 , but its not connecting, i am unable to get the service name , Screen shot attached. is there any settings i can…
-
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;…
-
EMA Example: opening item stream with a list of field IDs gets error with code -4048
Hi the following code (taken from the EMA Example series consumer/series300/ex360_MP_View: ReqMsg reqMsg = EmaFactory.createReqMsg() .name("/IBN.N") .serviceName("ELEKTRON_DD") .domainType(6); ElementList view = EmaFactory.createElementList(); OmmArray array = EmaFactory.createOmmArray(); array.fixedWidth(5);//Subscribe to…
-
ERROR: 'Attempt to submit initial RefreshMsg with service name of XYZ that was not included in the S
Hi, I am trying to publish data to our Local TREP infrastructure but I am getting the following error and not sure what it means. Can you please help? Exception Type='OmmInvalidUsageException', Text='Attempt to submit initial RefreshMsg with service name of XYZ that was not included in the SourceDirectory. Dropping this…
-
Provider accepting state interaction with ADH with discourageRequestsOnOutage enabled
We have an RSSL provider built against RFA 8.1 using the C++ API. When the process detects that it is becoming a slow consumer it should stop accepting new requests but to infer that all existing requests are still ok. This is currently communicated to the ADH by sending a directory message with: - load factor set to…
-
Migrating from sfc to EMA, NoDictionary errorcode.
We have a provider and consumer app developed with SFC. We are migrating to EMA. I'm working on the EMA provider to replace the SFC provider. When I send in an update request from the old SFC consumer, via the TREP servers, to the new EMA provider, I get the following postMsg with a NoDictionary error. PostMsg streamId="1"…
-
Initial image with large number of instruments
A batch request has more than 1000 instruemnts as a stream (intrest after refresh TRUE), the initial request take 30+seconds (initial image) what possibilities are there to improve the performance of the initial request.
-
OmmConsumer and DACS onbehalf
The recommendation is to use the least number of OmmConsumers, when creating the instance of the OmmConsumer the (DACS) username is provided, when having multiple users how to override the username for a different client being registered?
-
exceeded initialization timeout (5 s)
My connection stopped working and I can not understand the reason (if it is on my side or it is application level Reuters problem): These are what I know: 1.API:JAVA EMA 2.Error Msg: loggerMsg ClientName: ChannelCallbackClient Severity: Error Text: Received ChannelDown event on channel Channel_1 Instance Name Consumer_1_1…
-
EMA ommconsumer uninitialize() not working causing memory leak in Java
The flow of our application is: * create OmmConsumerConfig * pass config to newly created OmmConsumer * register interest, get the required data and unregister * finally we uninitialize() The problem we are seeing is that the connection is not closed. Every time the app runs it creates a new connection. This is causing…
-
Invalid attempt to close batch stream. Exception thrown in thomsonreuters::ema::access::OmmInvalidUs
Hi, I have this issue with consumer.unregister() in EMA C++ SDK 1.4.0L1 as well in 1.5.0.L1. The issue is that after I register a client (consumer is type OmmConsumer) using the batch mode, (thomsonreuters::ema::rdm::ENAME_BATCH_ITEM_LIST) UInt64 handle =…
-
Exception in thread "main" java.lang.NoClassDefFoundError: com/thomsonreuters/ema/access/OmmExceptio
Getting an exception when running through executable jar. working fine when running on IDE. Thanks in advance!
-
What does DataState StreamState Code Text mean and why do I receive it?
I'm receiving this line DataState <Suspect> StreamState <Open> Code <Preempted> Text <F7: Item Preempted> continuously for my RFA service but one I restarted it, it'll be gone.
-
Frequent Tunnel stream disconnection using EMA Java SDK 3.4.0.1 which is causing our service to publ
ced7e6a25126 ClientName: ChannelCallbackClient ced7e6a25126 Severity: Info ced7e6a25126 Text: Received ChannelUp event on channel BNC_Channel_1 ced7e6a25126 Instance Name BNC_Consumer_1 ced7e6a25126 Component Version eta3.1.1.L1.linux.rrg 64-bit Static ced7e6a25126 loggerMsgEnd ced7e6a25126 2020-02-11 23:04:10.530 INFO 1…
-
Null Payload in OmmMsg
Hi Team, We are migrating from RFA 7.6 to 8.1. We recently found a scenario in which Payload from OmmMsg was null, causing NullPointerException. Below is the snippet that caused the issue. From which we already verify that event and msg are not null. byte[] data = ommItemEvent.getMsg().getPayload().getBytes() Also this…
-
EMA InteractiveProvider- frequent disconnects
Hi, I have a Interactive provider (EMA 3.2) that is trying to publish large volumes of data for internal consumption. It seems to work as expected but we do get disconnected a few times by the ADH servers it seems. This is what we get in our logs: 06Dec 14:17:02.895 [pool-6-thread-1] ERROR…