[EMA Java] How to receive connection level events such as a disconnection?

andre.malenfant

I am trying to integrate EMA in our proprietary framework, where I need to publish events and alerts should the connection to Reuters fail. I cannot seem to be able to consume such events through the OmmConsumerClient interface.

What would be the best way to receive those? Do I need to manually issue a source directory request message?

When I forcibly close the connection by terminating the VPN, I see a message in the logs but the OmmConsumerClient is not called.

Example:

2018-11-29 09:39:07,157 WARN [pool-2-thread-1] |
com.thomsonreuters.ema.access.OmmConsumerImpl | | loggerMsg

ClientName: ChannelCallbackClient

Severity: Warning

Text: Received
ChannelDownReconnecting event on channel Channel

RsslReactor Channel is null

Error Id 0

Internal sysError 0

Error Location Reactor.processWorkerEvent

Error text Error - exceeded initialization timeout (5 s)

loggerMsgEnd

umer.nalla

Hi @andre.malenfant

If you want to monitor connection loss, you can explicitly registerClient for the MMT_LOGIN domain. This way you will receive Status Msg when the connection is lost and RefreshMsg when connection is restored and the application successfully logs back into the server again.

So, for example if I run the example example330 Login_Streaming,which registers for MMT_LOGIN (and IBM.N MarketPrice).

The stream with Item Handle 1 is the Login stream below.

When I disconnect my VPN I get the following:

Received Status. Item Handle: 1 Closure: null
Item Name: umer.nalla
Service Name: <not set>
Item State: Open / Suspect / None / 'channel down'
Received Status. Item Handle: 1 Closure: null
Item Name: <not set>
Service Name: <not set>
Item State: Open / Suspect / None / ''
Received Status. Item Handle: 2 Closure: null
Item Name: IBM.N
Service Name: ELEKTRON_DD
Item State: Open / Suspect / None / 'channel down.'

and when I reconnect my VPN I get:

Received Refresh. Item Handle: 1 Closure: null
Item Name: umer.nalla
Service Name: <not set>
Item State: Open / Ok / None / 'Login accepted by host test1-ads.'
Received Status. Item Handle: 1 Closure: null
Item Name: umer.nalla
Service Name: <not set>
Item State: Open / Ok / None / 'channel up'
Received Refresh. Item Handle: 2 Closure: null
Item Name: IBM.N
Service Name: ELEKTRON_DD

If you want to know about individual Service states i.e. if a particular service goes down and then comes back up, then you can register for MMT_DIRECTORY domain events as you mentioned above. This is demonstrated in example331 Directory_Streaming.
Note that if you specify a ServiceName, it will only provide information on that single service. If you want to know about all services, then omit the servicename.

consumer.registerClient(reqMsg.domainType(EmaRdm.MMT_DIRECTORY)
	.serviceName("ELEKTRON_DD"), appClient);