var rti = require('rticonnextdds-connector');

var connector = new rti.Connector("MyParticipantLibrary::Zero", "./ShapeExample.xml");
var output = connector.getOutput("MyPublisher::MySquareWriter");

// Write instances for 10 seconds
var i = 0;
var dt = new Date().getTime();
while (new Date().getTime() <= dt + 10000) {

    // write isntance with unique ID
    output.clear_members();
    output.instance.setNumber("x", 1);
    output.instance.setNumber("y", 2);
    output.instance.setNumber("shapesize", 30);
    output.instance.setString("color", "BLUE"+i.toString());
    output.write();

    console.log("Message sent , key = " + i.toString());

    i++;
}
console.log("Messages sent: " + i);

// timeout to keep app running, so that DDS could accomplish all the async sendings
setTimeout(justWait, 20000000);
function justWait() {
    console.log("Messages sent (2): " + i);
}