HemeraTestSuite

run_suite.js

const Hemera = require('nats-hemera')
const HemeraTestsuite = require('hemera-testsuite')
const PORT = 6242
let server

server = HemeraTestsuite.start_server(PORT, {}, (err, res) => {
  const nats = require('nats').connect(PORT)
  const hemera = new Hemera(nats)
  hemera.ready(() => {

    hemera.add({
      topic: 'math',
      cmd: 'add'
    }, function (resp, cb) {
      cb(null, resp.a + resp.b)
    })

    hemera.act({
      topic: 'math',
      cmd: 'add',
      a: 1,
      b: 2
    }, (err, resp) => {
      if (err) console.error(err)
      console.log(resp)
      hemera.close()
      server.kill()
    })
  })
})