queuemongodb v1.0.35

#Queue manager for mongoDB

##Create queuemangaer

    const jobHandler = new DBDequeuer({ 
      mongoURI: process.env.LOCAL_DB || '', // MongoURI NEEDED
      dbName: process.env.LOCAL_DB_LGM || '', // Mongo DB name NEEDED
      collectionName: 'jobshandler', // collection to use - NEEDED - will be created if not found 
      jobRetryDelay: 60000 * 60, // Delay in ms to retry failed job. Default to 1h = 3 600 000 ms
      maxRetry: 5, // Time to retry a failed job. Default 5
      refreshDelay: 250, // Queue refresh delay in ms. Default to 250 ms. 
    });

##Create job

    async jobHandler.add(jobType: string, jobData: any, scheduledAt?: number, customIdentifier?: string | number);
    // schedule job in 20 minutes
    Ex: await jobHandler.add('findemail', { firstname: 'boris', lastname: 'tchangang', domain: 'adomain.com' }, (new Date().getTime() + 20 * 3600 * 1000), 'scheduledAt-me-now'); 

Last parameter 'scheduledAt-me-now' in the example above is an identifier to identify an action in the queue. You can use this identifier later to check if an action is already waiting to be played in the queue.

##Retrieve a job

    async jobHandler.checkForActionScheduled(jobType: string, customIdentifier: string | number);
    // schedule job in 20 minutes
    Ex: await jobHandler.checkForActionScheduled('findemail', 'scheduledAt-me-now'); 

You can use this action to check if something similar is already pending in the queue.

Handle job

    jobHandler.on(jobType: string, conccurrency: number, callback)

• jobType should be type of job you want to dequeue.
• conccurrency is the number of parallel job allowed
• callback is a function that take 3 parameters:
  • first parameter is jobData
  • second is a function named complete that should be call when the job is complete to remove job from queue.
  • third is a function name requeue that should be call when the job failed to re-insert job in queue with a delay.

Exemple

   jobHandler.on('findemail', 10, async (jobData, complete, requeue) => {
     // jobData is { firstname: 'boris', lastname: 'tchangang', domain: 'adomain.com' }
     // process job data to whatever you want
     const email = await searchEmail(jobData.firstname, jobData.lastname, jobData.domain);
     if (email) {
       await saveEmail(email);
     }
     // call complete or requeue after
     complete();
   }); 

Feel free to ask new functionnalities if needed :-)