const Client = require('nsq-rpc')
let client = new Client({nsqdTCPAddresses: 'nsqd:4150'})

client.subscribe('sum.requests', (request, done) => {
  let result = request.a + request.b
  done(result)
})

let result = await client.request('sum.requests', {a: 1, b: 2})