subscribe-test.js

var appname = 'test.event.1'

var bus1 = require('servicebus').bus();
bus1.subscribe(appname, function (event) {
  console.log(`1 caught ${event.counter}`);
});
var bus2 = require('servicebus').bus();
bus2.subscribe(appname, function (event) {
  console.log(`2 caught ${event.counter}`);
});


var bus3 = require('servicebus').bus();
var counter = 0;
setInterval(function () {
  bus3.publish(appname, { counter });
  counter++;
}, 1000);