nsq-rpc v0.0.3

nsq-rpc

Implement RPC messaging pattern for NSQ wrapping original message with id and replyTo fields. Uses single replyTo topic per each client.

Basic usage

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})