Usage

Sender

const messages = await require('@dnode/messages')({
  redisUrl: process.env.REDIS_URL,
});
const id = messages.send({ example: 'example' });

Receiver

const messages = await require('@dnode/messages')({
  redisUrl: process.env.REDIS_URL,
});
messages
  .handle(async (message, id) => {
    console.log(`--- message (id: ${id})`);
    console.log(message);
  })
  .on('error', (err, message) => {
    console.log(err);
  });