Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
33 changes: 31 additions & 2 deletions test/nodejs/test_rticonnextdds_connector.js
Original file line number Diff line number Diff line change
Expand Up @@ -48,21 +48,50 @@ describe('Connector Tests', function () {
const connector = new rti.Connector(participantProfile, xmlProfile)
expect(connector).to.exist
expect(connector).to.be.instanceOf(rti.Connector)
connector.close()
})

it('Multiple Connector objects can be instantiated', function () {
it('Multiple Connector objects can be instantiated', () => {
const participantProfile = 'MyParticipantLibrary::Zero'
const xmlProfile = path.join(__dirname, '/../xml/TestConnector.xml')
const connectors = []
for (var i = 0; i < 5; i++) {
for (var i = 0; i < 3; i++) {
connectors.push(new rti.Connector(participantProfile, xmlProfile))
}
connectors.forEach((connector) => {
expect(connector).to.exist
expect(connector).to.be.instanceOf(rti.Connector)
connector.close()
})
})

// Test for CON-163
it('Multiple Connector obejcts can be instantiated without participant QoS', () => {
const participantProfile = 'MyParticipantLibrary::MyParticipant'
const xmlProfile = path.join(__dirname, '/../xml/TestConnector3.xml')
const connectors = []
for (var i = 0; i < 2; i++) {
connectors.push(new rti.Connector(participantProfile, xmlProfile))
}
connectors.forEach((connector) => {
expect(connector).to.exist
expect(connector).to.be.instanceOf(rti.Connector)
connector.close()
})
})

it('Load two XML files using the url group syntax', function () {
const xmlProfile1 = path.join(__dirname, '/../xml/TestConnector.xml')
const xmlProfile2 = path.join(__dirname, '/../xml/TestConnector2.xml')
const fullXmlPath = xmlProfile1 + ';' + xmlProfile2
const connector = new rti.Connector('MyParticipantLibrary2::MyParticipant2', fullXmlPath)
expect(connector).to.exist
expect(connector).to.be.instanceOf(rti.Connector)
const output = connector.getOutput('MyPublisher2::MySquareWriter2')
expect(output).to.exist
connector.close()
})

describe('Connector callback test', function () {
let connector

Expand Down
22 changes: 22 additions & 0 deletions test/xml/TestConnector2.xml
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
<?xml version="1.0"?>
<!--
(c) 2005-2019 Copyright, Real-Time Innovations. All rights reserved.
No duplications, whole or partial, manual or electronic, may be made
without express written permission. Any such copies, or revisions thereof,
must display this notice unaltered.
This code contains trade secrets of Real-Time Innovations, Inc.
-->

<dds xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:noNamespaceSchemaLocation="http://community.rti.com/schema/6.0.0/rti_dds_profiles.xsd"
version="6.0.0">

<!-- Participant library -->
<domain_participant_library name="MyParticipantLibrary2">
<domain_participant name="MyParticipant2" domain_ref="MyDomainLibrary::MyDomain">
<publisher name="MyPublisher2">
<data_writer name="MySquareWriter2" topic_ref="Square" />
</publisher>
</domain_participant>
</domain_participant_library>
</dds>
39 changes: 39 additions & 0 deletions test/xml/TestConnector3.xml
Original file line number Diff line number Diff line change
@@ -0,0 +1,39 @@
<?xml version="1.0"?>
<!--
(c) 2005-2020 Copyright, Real-Time Innovations. All rights reserved.
No duplications, whole or partial, manual or electronic, may be made
without express written permission. Any such copies, or revisions thereof,
must display this notice unaltered.
This code contains trade secrets of Real-Time Innovations, Inc.
-->

<dds xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:noNamespaceSchemaLocation="http://community.rti.com/schema/6.0.0/rti_dds_profiles.xsd"
version="6.0.0">
<!-- types -->
<types>
<struct name="SimpleType">
<member name="first" type="long"/>
</struct>
</types>

<!-- Domain Library -->
<domain_library name="MyDomainLibrary">
<domain name="MyDomain" domain_id="0">
<register_type name="SimpleType" type_ref="SimpleType" />
<topic name="Simple" register_type_ref="SimpleType"/>
</domain>
</domain_library>

<!-- Participant library -->
<domain_participant_library name="MyParticipantLibrary">
<domain_participant name="MyParticipant" domain_ref="MyDomainLibrary::MyDomain">
<publisher name="MyPublisher">
<data_writer name="MyWriter" topic_ref="Simple" />
</publisher>
<subscriber name="MySubscriber">
<data_reader name="MyReader" topic_ref="Simple" />
</subscriber>
</domain_participant>
</domain_participant_library>
</dds>