New posts are disabled while we improve the user experience.

You can browse the site, or for urgent issues, raise a query at MyAccount.

question

Upvotes
zoe avatar image
5 ●2 ●2 ●5

EMA OmmConsumer

API Version: RHEL8_64_GCC831

In EmaConfig.xml, we defined

<Consumer>

<Name value="consumer1"/>

<ChannelSet value="Channel_1, Channel_2"/>

<Logger value="Logger_1"/>

<Dictionary value="Dictionary_1"/>

<XmlTraceToStdout value="0"/>

</Consumer>


  1. When we construct OmmConsumer

mConsumer = new OmmConsumer(ommConsumerCfg);


If Channel_1 is not available, OmmException may be thrown

What is the suggest way to retry with Channel_2 when Channel_1 is not available during construct?


  1. What is the appropriate way to determine if the session is connected or disconnected from OmmConsumerEvent?


void EmaSession::onStatusMsg(const StatusMsg &statusMsg, const OmmConsumerEvent &event)


#productema-api
icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

1 Answer

· Write an Answer
Upvotes
Jirapongse avatar image
87.8k ●294 ●53 ●79

@zoe

Thank you for reaching out to us.

With the ChannelSet configuration, if the Channel_1 is not available, EMA will try to use the Channel_2. You can check this from the API log.

loggerMsg
    TimeStamp: 11:32:38.560
    ClientName: ChannelCallbackClient
    Severity: Warning
    Text:    Received ChannelDownReconnecting event on channel Channel_1
        Instance Name Consumer_1_1
        RsslReactor 0x00000227558EBBD0
        RsslChannel 0x00000227558EBBD0
        Error Id -1
        Internal sysError 10057
        Error Location D:\Jenkins\workspace\RTSDK_Core_DX1\OS\VS142-64\rcdev\source\rtsdk\Cpp-C\Eta\Impl\Reactor\rsslReactorWorker.c:2250
        Error Text <D:\Jenkins\workspace\RTSDK_Core_DX1\OS\VS142-64\rcdev\source\rtsdk\Cpp-C\Eta\Impl\Transport\rsslSocketTransportImpl.c:6165> Error: 1002 ipcConnecting() client connect() failed.  System errno: (10057)
loggerMsgEnd


loggerMsg
    TimeStamp: 11:32:45.619
    ClientName: ChannelCallbackClient
    Severity: Warning
    Text:    Received ChannelDownReconnecting event on channel Channel_2
        Instance Name Consumer_1_1
        RsslReactor 0x00000227558EBBD0
        RsslChannel 0x00000227558EBBD0
        Error Id -1
        Internal sysError 10057
        Error Location D:\Jenkins\workspace\RTSDK_Core_DX1\OS\VS142-64\rcdev\source\rtsdk\Cpp-C\Eta\Impl\Reactor\rsslReactorWorker.c:2250
        Error Text <D:\Jenkins\workspace\RTSDK_Core_DX1\OS\VS142-64\rcdev\source\rtsdk\Cpp-C\Eta\Impl\Transport\rsslSocketTransportImpl.c:6165> Error: 1002 ipcConnecting() client connect() failed.  System errno: (10057)
loggerMsgEnd

The exception is thrown due to the login request timeout (the LoginRequestTimeOut configuration). 

Exception Type='OmmInvalidUsageException', Text='login failed (timed out after waiting 45000 milliseconds)', ErrorCode='-4052'

As far as I know, EMA is a high level API which manages connections on behalf of the application. Typically, you can check if the session is connected or disconnected from the API log.


icon clock
10 |1500

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.

Write an Answer

Hint: Notify or tag a user in this post by typing @username.

Up to 2 attachments (including images) can be used with a maximum of 512.0 KiB each and 1.0 MiB total.