Calculator - Billing service RPC examples

a.calculator-service.js

// boilerplate to connect with RabbitMQ
const rabbit = require(‘./connect’);

rabbit.createQueue(‘add’, { durable: false }, (msg, ack) => {
  const numbers = JSON.parse(msg.content.toString());
  ack(null, numbers[0] + numbers[1]);
});

b.billing-service.js

const rabbit = require(‘./connect’);

async function consume() {
  const sum = await rabbit.getReply(‘add’, [1, 2]);
  console.log(sum);
}

consume();