EMA consumer error 107

shenping22975

Here is my Code, according to C++ EMA Cons113:

OmmConsumerConfig config;

EmaString itemName = "EUR=";

EmaString consumerName = "Consumer_4";

config.username("xxxxxx");

config.password("xxxxxx");

config.clientId("xxxxxx");

OmmConsumer consumer( config.consumerName( consumerName ) );

consumer.registerClient( ReqMsg().serviceName( "ELEKTRON_DD" ).name( itemName ), *this );

sleep( 900000 ); // API calls onRefreshMsg(), onUpdateMsg(), or onStatusMsg()

} catch ( const OmmException& excp ) {

cout << excp << endl;

It runs to line " OmmConsumer consumer( config.consumerName( consumerName ) );" and blocked here,with log as follow:

loggerMsg

TimeStamp: 15:40:45.631

ClientName: ChannelCallbackClient

Severity: Warning

Text: Received ChannelDownReconnecting event on channel Channel_4

Instance Name Consumer_4_1

RsslReactor 0x0xb6d74a0

RsslChannel 0x0xb6d74a0

Error Id -1

Internal sysError 107

Error Location

Error Text </local/jenkins/workspace/ESDKCore_RCDEV/OS/OL7-64/rcdev/source/rtsdk/Cpp-C/Eta/Impl/Transport/ripcsslutils.c:2049> Error: 1002 ripcSSLConnect() client connect() failed. System errno: (107)

loggerMsgEnd

loggerMsg

TimeStamp: 15:40:47.649

ClientName: ChannelCallbackClient

Severity: Warning

Text: Received ChannelDownReconnecting event on channel Channel_4

Instance Name Consumer_4_1

RsslReactor 0x0xb6d74a0

RsslChannel 0x0xb6d74a0

Error Id -1

Internal sysError 107

Error Location

loggerMsgEnd

loggerMsg

TimeStamp: 15:40:52.755

ClientName: ChannelCallbackClient

Severity: Warning

Text: Received ChannelDownReconnecting event on channel Channel_4

Instance Name Consumer_4_1

RsslReactor 0x0xb6d74a0

RsslChannel 0x0xb6d74a0

Error Id -1

Internal sysError 107

Error Location

loggerMsgEnd

The demo Cons113 on the same server runs Okay, while my codes reprort the former errors.

Please help check it, thanks.

Find more posts tagged with

c++

error

ema-api

refinitiv-realtime-optimised

#technology

Accepted answers

Jirapongse

@shenping22975

Sorry about the issue that you are facing.

I tested the code and it works fine on my machine.

void AppClient::onRefreshMsg( const RefreshMsg& refreshMsg, const OmmConsumerEvent& ) 
{
    cout << "Refresh" << endl;
     //cout << refreshMsg << endl;        // defaults to refreshMsg.toString()
}

void AppClient::onUpdateMsg( const UpdateMsg& updateMsg, const OmmConsumerEvent& ) 
{
    cout << "Update" << endl;
    //cout << updateMsg << endl;        // defaults to updateMsg.toString()
}

void AppClient::onStatusMsg( const StatusMsg& statusMsg, const OmmConsumerEvent& ) 
{
    cout << statusMsg << endl;        // defaults to statusMsg.toString()
}

int main( int argc, char* argv[] )
{ 
    try { 
        AppClient client;
        OmmConsumerConfig config;
        EmaString itemName = "EUR=";
        EmaString consumerName = "Consumer_4";
        config.username("username");
        config.password("password");
        config.clientId("clientID");
        OmmConsumer consumer(config.consumerName(consumerName));
        consumer.registerClient(ReqMsg().serviceName("ELEKTRON_DD").name(itemName), client);
        sleep(900000); // API calls onRefreshMsg(), onUpdateMsg(), or onStatusMsg()
    }
    catch (const OmmException& excp) {
        cout << excp << endl;
    }
    return 0;
}

You may check the EMAConfig.XML which contains the correct configurations.

        <Consumer>
            <Name value="Consumer_4"/>


            <!-- ChannelSet specifies an ordered list of Channels to which OmmConsumer will attempt to    -->
            <!-- connect, one at a time, if the previous one fails to connect                            -->
            <ChannelSet value="Channel_4"/>


            <Logger value="Logger_1"/>
            <Dictionary value="Dictionary_2"/>
            <XmlTraceToStdout value="0"/>
            <XmlTraceToFile value="0"/>
            <RestEnableLog value="0"/>
        </Consumer>


...
...
        <Channel>
            <Name value="Channel_4"/>
            <ChannelType value="ChannelType::RSSL_ENCRYPTED"/>
            <CompressionType value="CompressionType::None"/>       
            <GuaranteedOutputBuffers value="5000"/>
            <!-- EMA discovers a host and a port from RDP service discovery for the specified location 
                when both of them are not set and the session management is enable. -->
            <Location value="us-east-1"/>
            <EnableSessionManagement value="1"/>
            <EncryptedProtocolType value="EncryptedProtocolType::RSSL_SOCKET"/>
            <!-- ObjectName is optional: defaulted to ""                                                -->
            <ObjectName value=""/>
        </Channel>

I hope that this information is of help

All comments

Jirapongse

@shenping22975

Sorry about the issue that you are facing.

I tested the code and it works fine on my machine.

void AppClient::onRefreshMsg( const RefreshMsg& refreshMsg, const OmmConsumerEvent& ) 
{
    cout << "Refresh" << endl;
     //cout << refreshMsg << endl;        // defaults to refreshMsg.toString()
}

void AppClient::onUpdateMsg( const UpdateMsg& updateMsg, const OmmConsumerEvent& ) 
{
    cout << "Update" << endl;
    //cout << updateMsg << endl;        // defaults to updateMsg.toString()
}

void AppClient::onStatusMsg( const StatusMsg& statusMsg, const OmmConsumerEvent& ) 
{
    cout << statusMsg << endl;        // defaults to statusMsg.toString()
}

int main( int argc, char* argv[] )
{ 
    try { 
        AppClient client;
        OmmConsumerConfig config;
        EmaString itemName = "EUR=";
        EmaString consumerName = "Consumer_4";
        config.username("username");
        config.password("password");
        config.clientId("clientID");
        OmmConsumer consumer(config.consumerName(consumerName));
        consumer.registerClient(ReqMsg().serviceName("ELEKTRON_DD").name(itemName), client);
        sleep(900000); // API calls onRefreshMsg(), onUpdateMsg(), or onStatusMsg()
    }
    catch (const OmmException& excp) {
        cout << excp << endl;
    }
    return 0;
}

You may check the EMAConfig.XML which contains the correct configurations.

        <Consumer>
            <Name value="Consumer_4"/>


            <!-- ChannelSet specifies an ordered list of Channels to which OmmConsumer will attempt to    -->
            <!-- connect, one at a time, if the previous one fails to connect                            -->
            <ChannelSet value="Channel_4"/>


            <Logger value="Logger_1"/>
            <Dictionary value="Dictionary_2"/>
            <XmlTraceToStdout value="0"/>
            <XmlTraceToFile value="0"/>
            <RestEnableLog value="0"/>
        </Consumer>


...
...
        <Channel>
            <Name value="Channel_4"/>
            <ChannelType value="ChannelType::RSSL_ENCRYPTED"/>
            <CompressionType value="CompressionType::None"/>       
            <GuaranteedOutputBuffers value="5000"/>
            <!-- EMA discovers a host and a port from RDP service discovery for the specified location 
                when both of them are not set and the session management is enable. -->
            <Location value="us-east-1"/>
            <EnableSessionManagement value="1"/>
            <EncryptedProtocolType value="EncryptedProtocolType::RSSL_SOCKET"/>
            <!-- ObjectName is optional: defaulted to ""                                                -->
            <ObjectName value=""/>
        </Channel>

I hope that this information is of help

EXPLORE OUR SITES