1.0.0 • Published 6 years ago
@dnode/messages v1.0.0
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);
});
1.0.0
6 years ago