Listening for connection errors for RTO

simon.dando

We are connected to RTO 24/7 and we sometimes see connection errors during your maintenance window. When implementing a solution to reconnect, we didn't see that we could listen for connection errors and hence reconnect some time after seeing the event. Please advise if we can do this or pls raise an enhancement request. Currently if we see a connection error when requesting data we can only reconnect then (and probably will require retries) hence our clients won't receive market data in a timely fashion.

This is the usual connection error that we see:

2022-05-29 05:05:42,629 [pool-5-thread-1] ERROR c.r.ema.access.OmmConsumerImpl - loggerMsg

ClientName: LoginCallbackClient

Severity: Error

Text: RDMLogin stream was closed with status message

username <removed>

usernameType 1

State: Closed/Suspect/Not entitled - text: "Force Logout from DACS."

loggerMsgEnd

Jirapongse

@simon.dando

I tested the following code in ex113.

consumer  = EmaFactory.createOmmConsumer(config.consumerName(connectWebSocket ? "Consumer_5" : "Consumer_4"));

LoginReq loginReq = EmaFactory.Domain.createLoginReq();
consumer.registerClient(loginReq.message(), appClient);
            

It works properly.

The example can get the login refresh and status messages properly.

    public void onRefreshMsg(RefreshMsg refreshMsg, OmmConsumerEvent event)
    {
        if(refreshMsg.domainType() == EmaRdm.MMT_LOGIN)
        {
            System.out.println("#### Login Refresh #####");
        }
        System.out.println(refreshMsg);
    }


    public void onUpdateMsg(UpdateMsg updateMsg, OmmConsumerEvent event)
    {
        if(updateMsg.domainType() == EmaRdm.MMT_LOGIN)
        {
            System.out.println("#### Login Update #####");
        }
        System.out.println(updateMsg);
    }


    public void onStatusMsg(StatusMsg statusMsg, OmmConsumerEvent event)
    {
        if(statusMsg.domainType() == EmaRdm.MMT_LOGIN)
        {
            System.out.println("#### Login Status #####");
        }
        System.out.println(statusMsg);
    }

The output is:

#### Login Refresh #####
RefreshMsg
    streamId="1"
    domain="Login Domain"
    solicited
    RefreshComplete
    state="Open / Ok / None / 'Login accepted by host WIN-2NOVD7CLMV1'"
    itemGroup="00 00"
    Attrib dataType="ElementList"
        ElementList
            ElementEntry name="ApplicationId" dataType="Ascii" value="256"
            ElementEntry name="ApplicationName" dataType="Ascii" value="rsslProvider"
            ElementEntry name="Position" dataType="Ascii" value="192.168.0.184/WIN-2NOVD7CLMV1"
            ElementEntry name="ProvidePermissionProfile" dataType="UInt" value="1"
            ElementEntry name="ProvidePermissionExpressions" dataType="UInt" value="1"
            ElementEntry name="SingleOpen" dataType="UInt" value="0"
            ElementEntry name="AllowSuspectData" dataType="UInt" value="1"
            ElementEntry name="SupportPauseResume" dataType="UInt" value="0"
            ElementEntry name="SupportOptimizedPauseResume" dataType="UInt" value="0"
            ElementEntry name="SupportOMMPost" dataType="UInt" value="1"
            ElementEntry name="SupportViewRequests" dataType="UInt" value="0"
            ElementEntry name="SupportBatchRequests" dataType="UInt" value="5"
            ElementEntry name="SupportStandby" dataType="UInt" value="0"
        ElementListEnd
    AttribEnd
RefreshMsgEnd
...
...
#### Login Status #####
StatusMsg
    streamId="1"
    domain="Login Domain"
    state="Closed / Suspect / Not entitled / 'Simulated Force Logout from DACS.