What do these ADS errors mean and how do I detect the errors on a subscribe client

https://community.developers.refinitiv.com/questions/56634/need-to-understand-few-extra-details-on-disconnect.html

I don't believe that is currently possible in EMA to check if the event queue is getting too big - I have asked the dev team if this is something they can add to a future version - I will let you know.

In terms of detecting slow consumer scenario, you could check a timestamp field of the received data and if you detect considerable latency then you deduce that the data is being read too slowly and the events are being queued up.

In terms of checking if the application is still logged into the server, you can access the Login stream as demonstrated in examples

example330__Login__Streaming and example333__Login__Streaming__DomainRepresentation

With the above examples the OmmConsumerClient receives messages for the Login stream - so when logged out you can expect to receive a Closed StatusMsg for the Login.

You can also extract the ChannelInformation from the OmmConsumerEvents as mentioned in

https://community.developers.refinitiv.com/questions/35516/ema-java-how-to-receive-connection-level-events-su.html

https://community.developers.refinitiv.com/questions/55369/how-to-determine-which-channel-is-down-and-reason.html

In addition to processing the callback faster, you can also use Horizontal Scaling - i.e. multiple OmmConsumer instances on a multi-core CPU - so that the processing workload is split across the cores and illustrated in example410__MarketPrice__HorizontalScaling

All comments

https://community.developers.refinitiv.com/questions/27666/elektron-emaconfigxml-consumer-buffer-tuning.html

A few existing posts on the same issue which should help

https://community.developers.refinitiv.com/questions/14322/ema-issue-with-update-items.html

https://community.developers.refinitiv.com/questions/6590/rfa-api-connect-fail-in-murex.html

Essentially an application is not consuming the data quickly enough and the ADS can only buffer so much for each application - eventually it will disconnect the problem application.

pimchaya.wongrukun01

Hello @duncan_kerr

Please see the Solution section in this article to consume data quickly in RFA application.

Hi Umer - thanks for quick answer. I understand that we need to process data faster & how to do that. What I dont understand is:

how do I monitor the queuing in the API? Can I get an idea of when we are running into trouble?
how do I get notified when the queue fills up & we start to lose data?

Hi Pimchaya - I understand that we need to process data faster & how to do that. What I dont understand is:

how do I monitor the queuing in the API? Can I get an idea of when we are running into trouble?
how do I get notified when the queue fills up & we start to lose data?

Please confirm which API and language you are using so we can provide the appropriate advice.

We are using EMA Java. I understand that we need to process the onMarketData callback faster, what I want to know is, how do we detect the error condition on a RIC level, and on a channel level?

https://community.developers.refinitiv.com/questions/56634/need-to-understand-few-extra-details-on-disconnect.html

In terms of checking if the application is still logged into the server, you can access the Login stream as demonstrated in examples

example330__Login__Streaming and example333__Login__Streaming__DomainRepresentation

With the above examples the OmmConsumerClient receives messages for the Login stream - so when logged out you can expect to receive a Closed StatusMsg for the Login.

You can also extract the ChannelInformation from the OmmConsumerEvents as mentioned in

https://community.developers.refinitiv.com/questions/35516/ema-java-how-to-receive-connection-level-events-su.html

https://community.developers.refinitiv.com/questions/55369/how-to-determine-which-channel-is-down-and-reason.html

Umer - if the event queue becomes too big & the ADS drops ticks, which status messages would you expect to get? Presumably the ADS doesnt drop the link & send a LoggedOut message on the Login stream?

If we go for the checking timestamps method, would we have to chose which timestamps to compare on the message, or can you recommend the relevant FIDs? Does the ADS timestamp the message when its queued/dequeued?

thanks all - Im working through your various suggestions as well as increasing performance. can you confirm, though, when we have a slow consumer, and the ADS runs out of buffer space, what is the sequence of events? Dooes the whole channel go down, or do we just get transient errors of some RICS?