amqpc v0.0.7

amqpc

Usage

(async() => {
  const conn = await amqplib.connect('amqp://rabbitmq:rabbitmq@localhost');

  await runServer(conn);
  await runClient(conn);

})().catch(err => console.error(err));


async function runServer(conn) {
  const ch = await conn.createChannel();
  const server = new AmqpcServer(ch);
  server.define('foo', async (bar, baz) => {
    return 'hello world';
  });
}

async function runClient(conn) {
  const ch = await conn.createChannel();
  const client = new AmqpcClient(ch);

  const result = await client.call('foo', 'bar', 'baz');
  console.log('result', result);
}