@dnode/messages
1.0.0 • Public • Published
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);
});
Dependencies (2)
Dev Dependencies (0)
Package Sidebar
Install
Weekly Downloads