class AppClient : public refinitiv::ema::access::OmmProviderClient |
{ |
protected : |
void onRefreshMsg( const refinitiv::ema::access::RefreshMsg&, const |
refinitiv::ema::access::OmmProviderEvent& ); |
void onStatusMsg( const refinitiv::ema::access::StatusMsg&, const |
refinitiv::ema::access::OmmProviderEvent& ); |
bool _bConnectionUp; |
}; |
void AppClient::onRefreshMsg( const RefreshMsg& refreshMsg, const OmmProviderEvent& |
ommEvent ) |
{ |
cout << endl << "Handle: " << ommEvent.getHandle() << " Closure: " << |
ommEvent.getClosure() << endl; |
cout << refreshMsg << endl; |
if ( refreshMsg.getState().getStreamState() == OmmState::OpenEnum ) |
{ |
if ( refreshMsg.getState().getDataState() == OmmState::OkEnum ) |
_bConnectionUp = true; |
else |
_bConnectionUp = false; |
} |
else |
_bConnectionUp = false; |
} |