How to establish multiple connections using RFA API

ryusuke.kamimura

Is it possible for RFA API to establish multiple connections (to a same host but different ports ) ?

i.e.

Destination/publisher host:

Test_Host1

Ports:

- 10101

- 10102

..

- 10108

We have configured like below but it seems it just only connect to one of them :

===================

<?xml version="1.0" encoding="UTF-8"?>

<EmaConfig>

<ConsumerGroup>

<DefaultConsumer value="Consumer_1"/>

<ConsumerList>

<Consumer>

<Name value="Consumer_1"/>

<ChannelSet value="Channel_1, Channel_2"/>

<Logger value="Logger_1"/>

<Dictionary value="Dictionary_1"/>

<XmlTraceToStdout value="0"/>

</Consumer>

</ConsumerList>

</ConsumerGroup>

<ChannelGroup>

<ChannelList>

<Channel>

<Name value="Channel_1"/>

<ChannelType value="ChannelType::RSSL_SOCKET"/>

<CompressionType value="CompressionType::None"/>

<GuaranteedOutputBuffers value="5000"/>

<ConnectionPingTimeout value="30000"/>

<TcpNodelay value="1"/>

<Host value="test_host1"/>

<Port value="10101"/>

</Channel>

<Channel>

<Name value="Channel_2"/>

<ChannelType value="ChannelType::RSSL_SOCKET"/>

<CompressionType value="CompressionType::None"/>

<GuaranteedOutputBuffers value="5000"/>

<Host value="test_host1"/>

<Port value="10102"/>

</Channel>

</ChannelList>

</ChannelGroup>

<LoggerGroup>

<LoggerList>

<Logger>

<Name value="Logger_1"/>

<LoggerType value="LoggerType::Stdout"/>

<LoggerSeverity value="LoggerSeverity::Success"/>

</Logger>

</LoggerList>

</LoggerGroup>

<DictionaryGroup>

<DictionaryList>

<Dictionary>

<Name value="Dictionary_1"/>

<DictionaryType value="DictionaryType::FileDictionary"/>

<RdmFieldDictionaryFileName value="./RDMFieldDictionary"/>

<EnumTypeDefFileName value="./enumtype.def"/>

</Dictionary>

</DictionaryList>

</DictionaryGroup>

</EmaConfig>

===============================

Could you pleaes let us know how to properly configure it ? Thank you

wasin.w V3

Hello @ryusuke.kamimura

I did a quick test with EMA API C++ version 3.6.7 (RTSDK 2.0.7) Cons410 example connects to the following sources:

• Consumer 1: Connect to RTC/ADS Pop on my local machine port 14002
• Consumer 2: Connect to EMA Java IProvider on my local machine port 14022

The modification code of Cons410 is as follows:

try {
    // Create two ConsumerManager objects to demonstrate horizontal scaling feature on user thread of control
    ConsumerManager consumerMgr1( "localhost:14002", "user1" );
    ConsumerManager consumerMgr2("localhost:14022", "user2");
        
    AppClient appClient1;
    AppClient appClient2;


    consumerMgr1.getOmmConsumer().registerClient( ReqMsg().serviceName( "ELEKTRON_DD" ).name( "/VOD.L" ), appClient1, (void *)"consumerMgr1" );
    consumerMgr2.getOmmConsumer().registerClient( ReqMsg().serviceName( "ELEKTRON_DD" ).name( "TRI.N" ), appClient2, (void *)"consumerMgr2" );


    // Start dispatching messages from each ConsumerManager
    consumerMgr1.start();
    consumerMgr2.start();


    sleep( 60000 );                // User thread calls onRefreshMsg(), onUpdateMsg(), or onStatusMsg()


    consumerMgr1.stop();
    consumerMgr2.stop();
}

Results:

The EMA API Horizontal Scaling example is available on the EMA C++ as Cons410 example. The example is available on the SDK package which can be downloaded from the following sites:

• RTSDK C/C++ download page on the Developer Portal
• RTSDK GitHub Page

result-1.png

result-2.png