Bull queue example for adding a chat message every 2 seconds

queue.js

const Queue = require('bull');

const app = require('./app');
const redisUrl = 'redis://localhost:6379';
const messageQueue = new Queue('add-message', redisUrl, {
  defaultJobOptions: {
    removeOnComplete: true
  }
});

messageQueue.process(async job => {
  const [ user ] = await app.service('users').find({
    paginate: false,
    query: {
      email: '[email protected]'
    }
  });

  const message = await app.service('messages').create({
    text: `Message from job #${job.id}`
  }, { user });

  console.log('Processed message', message);
});

messageQueue.add({}, {
  repeat: {
    every: 2000
  }
});

Amazing work. Their library is so flexible and most of all well documented.