02__TimeSeries_Test_Publisher.js

var Thread = Java.type("java.lang.Thread");
var System = Java.type("java.lang.System");
var String = Java.type("java.lang.String");

var topic = "service/ping";

function execute(action) {
    out("Test Script: " + action.getName());
    for (var i = 0; i < 1000; i++) {
        randomTimeSeriesPing();
        Thread.sleep(2000);
    }
    action.setExitCode(0);
    action.setResultText("done.");
    out("Test Script: Done");
    return action;
}

function randomTimeSeriesPing() {
    var millis = System.currentTimeMillis();
    out("time published: " + millis);

    var message = String.format("{ \"timestamp\": %d, \"value\": %f }",  millis, Math.random()*100);
    mqttManager.publish(topic, message);
}

function out(message){
     output.print(message);
}