How to make OmmConsumerClient recover from Open / Suspect / None state

Konrad
Konrad Newcomer
in TREP APIs

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 something with the status and payload
    }
@Override
    public void onUpdateMsg(UpdateMsg msg, OmmConsumerEvent consumerEvent) {
       // make use of payload
    }

@Override
    public void onStatusMsg(StatusMsg msg, OmmConsumerEvent consumerEvent) {
       // make use of ommstate
    }
}

The consumption is going ok, i.e. after subscribing I get a refresh message, and then update messages with payload.

When there is a problem with a connection, a state update comes in, in a form of status message. The state is: ""Open / Suspect / None / 'A23: Source has gone down, requesting from another source.'".

However, the RIC is fixed on a server after some time and is flowing again, but NOT to my application, this subscription goes stale. How can I set up the subscription so that it recovers, when the RIC is alive again?

One workaround is to kill this subscription and recreate it - this works fine, but doesn't seem to be the best way.

Tagged:

Best Answer

  • wasin.w
    wasin.w admin
    Answer ✓

    Hello @Konrad

    The stream state "Open / Suspect" indicates that the item stream remains opened but data is not available. The application should be able to receive data as usual after the service is recovered.

    Can you replicate the issue on demand? If so, please enable the EMA XML trace message and replicate the issue. The XML trace messages contain incoming/outgoing messages between the API and ADS server. It helps to verify if the API receives any messages from the ADS after recovery.

    Please check the XML Trace section of the Enterprise Message API (EMA) - Configuration Overview article to see how to enable the EMA trace messages.

    Additionally, can you give us more detail about the application that encounters the issue?

    • Is it EMA Java or C/C++?
    • The version of EMA
    • OS
    • Compiler


Answers

Categories