cannasos-rpc v0.0.15

CannaSOS RPC

API reference

Constructor

new Rpc(connectionString, options)

Rpc methods

connect(next)

disconnect(next)

register(serviceName, handler, next)

call(serviceName, method, args, next)

Example

const rpc = new Rpc('amqp://user:password@hostname');
rpc.connect((err) => {
  if (err) { return next(err); }
  rpc.register('testServer', new Server(), (err) => {
    if (err) { return next(err); }
    rpc.call('testServer', 'testSqr', {val: 2}, (err, res) => {
      if (err) { return next(err); }
      console.log(res);
    });
  });
});