Merge d245d9e into e3a6323

stitchng · Nov 1, 2019 · c52ac40 · c52ac40
2 parents e3a6323 + d245d9e
commit c52ac40
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 0 deletions.
diff --git 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.delayUntil = Date.parse('2038-01-19T03:14:08.000Z') // optional, omit this line if not required
 	}
 
 	async handle(link, done) {

diff --git 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()
               }
             }