rhea.js publisher

var container = require("rhea");
const { HOST, PORT, NODE_TOPIC, USERNAME, PASSWORD } = require("../env");

container.options.username = USERNAME; // guest
container.options.password = PASSWORD; // guest

const host = `${HOST}:${PORT}/${NODE_TOPIC}`; // localhost:5672/amq.topic
const topic = "objects.bed.update";

console.log(container.options, host, topic);

var connection = container.connect(host);

var sender = connection.open_sender(topic);
sender.on("sendable", function(context) {
  for (var i = 0; i < args._.length; i++) {
    var m = args._[i];
    console.log("sent " + m);
    sender.send({ body: m });
  }
  connection.close();
});