When i restart back-end service bull queue doesn't send mails which was in queue?

[Hspharwinder]

I set delay time of bull queue 3 minute and send mail. I restart backend service but after 3 minute i did not receive any mail.

when i do not restart backend service it is working fine.

I don't know why bull doesn't send mails after restart service

[manast]

You need to provide a small and concrete example code in order for anybody to give you some help.

[Hspharwinder]

const options = {
  delay: 180000, // 3 min in ms
};

let requestShoutJobPerformer = createQueue(keys.SEND_MAIL, {
	to: result.performer.email,
	template: 'request_shout_out_performer',
	data: {
		{
                     performerName: result.performer.firstName + ' ' + result.performer.lastName,
		     userName: result.user ? result.user.firstName + ' ' + result.user.lastName : { name: Constants.UNKNOW },
		     type: Constants.EMAIL_TEMPLATE_TYPE[0],
		     videoUrl: data.videoId ? config.shoutoutUrl + data._id : ''
                },
		title: "You got a shoutout request !",
		orderUrl: `${config.reactUrl}shoutout/${data._id}/success`
	}					
}, options);

if (requestShoutJobPerformer) {
	emailProcess(requestShoutJobPerformer)
}





/**
 * Create Queue of emails in bull
*/

let redis = {
    port: config.redis.port,
    host: config.redis.host,
    password: config.redis.pass,
    // db: config.redis.db, // if provided select a non-default redis db
};

const createQueue = function (param, data, options) {
    const Queue = new Bull(param, {
      redis: redis,
    });
  
    Queue.add(data, options);
    return Queue;
};





/**
 * Manage event of emails
 */
import { Mailer } from '../components';
import keys from '../config/keys';

exports.emailProcess = (queue) => {
  if (queue.name == keys.SEND_MAIL) {
    queue.process((job, done) => {
      Mailer.sendMail(job.data.template, job.data.to, Object.assign({ subject: job.data.subject }, job.data.data), (err) => {
        if (err) {
          console.log("<====err====>", err)
          done(err);
        }
      });
      done();
    });
  }
};