const Manager = require('beatrix-events');
Manager.connect({
name: 'blah',
uri: 'amqp://guest:guest@localhost/'
});
Manager.on('colony.people', {
persistent: true,
filter: {age: {$gt: 30}}
}, async (person) => {
if (person.name > 'Logan') {
throw new Error('Run, Logan, Run')
}
return person.name + ' was eliminated for the greater good';
})
setInterval(() => {
Manager.emit('colony.people', generateRandomPerson());
}, 1000);