You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
constQueue=require("bee-queue");constqueue=newQueue("http-sender");constjob=queue.createJob({timestamp: Date.now(),});job.backoff("exponential",1000);job.retries(3);job.save();job.on("succeeded",(result)=>{console.log(`${job.id}: sent`);});queue.process((job,done)=>{console.log(`Processing job ${job.id}`);returndone(newError("test"));});queue.on("failed",(job,err)=>{console.log(`Job ${job.id} failed with error ${err.message}`);});queue.on("retrying",(job,err)=>{console.log(`Job ${job.id} failed with error ${err.message} but is being retried!`);});
The text was updated successfully, but these errors were encountered:
This is evidently not called out in the README, but you need activateDelayedJobs enabled for the retries feature. We can't make the Job#retries function fail if you don't configure that, because in some contexts you may desire to have the job processor entirely separate from the job producer.
Code to reproduce
The text was updated successfully, but these errors were encountered: