index.js

const Queue = require('bull');
const sendMail = require('../utils/sendMail');

  const welcomeMailJob = async (payload) => {
    /** Initializing the Queue */	
    const sendMailQueue = new Queue('sendMail', {	
      redis: {	
        host: process.env.LOCAL_HOST,	
        port: process.env.REDIS_PORT,	
      },	
    });	

    /** Build data & options object */
    const data = {
      to: payload.email,
      subject: '🌍 Warm welcome from Company',
      body: "Welcome to this company.",
    };
    const options = {delay: 5000, attempts: 3};

    /** Adding a Job to the Queue */
    sendMailQueue.add(data, options);

    /** Consumer */
    sendMailQueue.process(async (job) => await sendMail(job.data));
  }

module.exports = welcomeMailJob;