diff --git a/README.md b/README.md index 1766a7c..8334169 100644 --- a/README.md +++ b/README.md @@ -59,6 +59,7 @@ class SendEmail extends Job { this.timeOut = 50; // seconds this.retryCount = 3; this.retryUntil = 200; // seconds + this.delay = Date.parse('2038-01-19T03:14:08.000Z') // // omit this line if not required } async handle(link, done) { diff --git a/src/Queue/index.js b/src/Queue/index.js index aa6f499..446903c 100644 --- a/src/Queue/index.js +++ b/src/Queue/index.js @@ -141,6 +141,7 @@ class Queue { .timeout(job.timeOut || 0) .backoff('fixed', job.retryUntil || 0) .retries(job.retryCount || 2) + .delayUntil(job.delayUntil || 0) .save(async (err, $job) => { // See: https://github.com/bee-queue/bee-queue/issues/147 if (err) { console.error(`@@adonisjs/Queue: failed in creating job id=${this._jobUuid} on queue: ${_name}`) @@ -160,6 +161,7 @@ class Queue { .timeout(job.timeOut || 0) .backoff('fixed', job.retryUntil || 0) .retries(job.retryCount || 2) + .delayUntil(job.delayUntil || 0) .save() } }