Hello @azat.kasimov ,

I do not believe you will be able to manipulate this aspect with Ex430, it is not intended for RTO connectivity.

What you observe looks right to me. If you register for Login domain events, you should be seeing events on login stream such as Login Accepted, Channel Up, Channel Down, however, on login stream closure if there is a channel that is established on a specific Domain, from my testing, it will supersede, and login closure will be reported on that Domain status. If it's MarketPrice - on MarketPrice, if it's NewsTextAnalytics - on NewsTextAnalytics. From my testing with the latest SDK, you can expect to see login stream closure on your established channel even without registering for Login domain.

Please note, that this configuration is not a sure-fire way to reproduce and is suggested based on guess, with the sole purpose to increase the incident of the issue manifesting, and IS NOT recommended for any other purpose, including production or development usage. I would suggest something like:

<Consumer>  
  <Name value="Consumer_4"  
  <Channel value="Channel_4"  
  <Dictionary value="Dictionary_1"  
  <MaxDispatchCountApiThread value="6500"  
  <MaxDispatchCountUserThread value="6500"/>  
  <XmlTraceToStdout value="1"/>  
  <TokenReissueRatio value="0.95"/> 
</Consumer>

Please refer to EMA Configuration Guide for additional information on EMA config.

By enabling trace you should also be able to collect additional information, and it may come helpful in understanding the cause of the issue.

Hello @azat.kasimov ,

Would like to suggest to register for Login domain, to track the state of the stream in onStatusMsg callback and to handle it, similar to:

LoginReq loginReq = EmaFactory.Domain.createLoginReq();

consumer.registerClient(loginReq.message(), appClient);

Please find this in example series300.ex333_Login_Streaming_DomainRep in SDK.

This should be a rare scenario, but you are absolutely correct- a consumer intended for production use should handle this scenario.

Parsing logger messages can be done, but is not a reliable or recommended approach to handling.

This specific situation, I can not think of a reliable approach to simulate, other then running and connecting to a custom publisher.

If you are on a developer machine, or on a test environment, you can simulate a network interrupt in general, by unplugging your wired network connection, waiting for the API to detect the disconnect, and plugging back in, or disconnecting and reconnecting the specific WiFi conn.

I would like to suggest, if it is possible on your side, to run with the latest version of RTSDK on GitHub as some reliability issues have been fixed even at the very latest release.

We have already raised the issue with RTO support. They are having some issues on their side which causes this to be a persistent issue, so we would like to implement a solution to this issue on our side regardless .

I am looking into adjusting the refresh rate to exceed the required rate to force the error. Is this possible by adjusting ex.430? I understand that this Reissue Ratio can also be set in the EmaConfig.xml file. Could you please point me to where in the config file I can set this?

Moreover, I have implemented the login domain to attempt to track disconnects. Since I can't recreate the issue exactly as of yet, it is difficult to interpret whether it can be used to catch the issue and reconnect. Upon initial connection, I get the following printed to console for the login domain stream and the NewsTextAnalytics Domain:

RefreshMsg
    streamId="1"
    domain="Login Domain"
    solicited
    RefreshComplete
    state="Open / Ok / None / 'Login accepted by host ads-fanout-sm-az2-use1-prd.'"
    itemGroup="00 00"
    name= XXX
    nameType="1"
    Attrib dataType="ElementList"

RefreshMsg
    streamId="5"
    domain="NewsTextAnalytics Domain"
    solicited
    RefreshComplete
    state="Open / Ok / None / ''"
    itemGroup="00 0b"
    permissionData="03 01 01 10 00 2c"
    name="MRN_TRNA"
    nameType="1"
    serviceId="257"
    serviceName="ELEKTRON_DD"

However, I do not get any StatusMsg on the Login Domain when I close the stream manually using:

consumer.uninitialize();

I only see:

StatusMsg
    streamId="5"
    domain="NewsTextAnalytics Domain"
    state="Closed / Suspect / None / 'Login stream was closed.'"
    name="MRN_TRNA"
    serviceId="257"
    serviceName="ELEKTRON_DD"
StatusMsgEnd

Additionally, our logs indicate that the we do not catch a StatusMsg when the issue occurs, we only see the loggerMsg error:

Aug 10, 2021 10:50:07 PM com.refinitiv.ema.access.LoginCallbackClient rdmLoginMsgCallback
SEVERE: loggerMsg
    ClientName: LoginCallbackClient
    Severity: Error
    Text:    RDMLogin stream was closed with status message
        username XXX
        usernameType XXX

        State: Closed/Suspect/Timeout - text: "TREP authentication token has expired."
loggerMsgEnd

Will this error be caught in the onStatusMsg if the Login Domain is monitored? Is there any other way to check the state of the stream connection by streamId?

Thank you for your response.

I was able to recreate the TREP issue, although it was by attempting multiple reconnects. It looks like the issue is indeed caught on the LOGIN stream.

The issue I'm encountering now is programming the reconnect logic. I am initially trying to close the stream using:

consumer.uninitialize();
serviceDiscovery.uninitialize();

However, when I try to re-connect by re-initializing the OmmConsumer, ServiceEndpointDiscovery, AppClient and other variables using the same initialization code as the first connection, I get the following message:

Aug 16, 2021 3:39:07 PM com.refinitiv.ema.access.ChannelCallbackClient reactorChannelEventCallback
INFO: loggerMsg
    ClientName: ChannelCallbackClient
    Severity: Info
    Text:    Received ChannelUp event on channel Channel_1
    Instance Name Consumer_1_2
    Component Version ads3.4.2.L1.linux.tis.rrg 64-bit
loggerMsgEnd

As you can see, the Instance Name is Consumer_1_2. I can also see that there are previous threads running from the initial connection. I'm assuming these threads retain information from the initial connection, resulting in this Instance Name. I would like the re-connect to simulate a fresh connection with Instance Name Consumer_1_1, with the previous threads closed, as this could cause memory issues down the line.

Is there any way to do this? Can I manually stop the previous threads from running to achieve this?

Thank you