node-resque
Advanced tools
Comparing version 8.0.2 to 8.0.3
@@ -36,3 +36,3 @@ /// <reference types="node" /> | ||
*/ | ||
enqueueIn(time: number, q: string, func: string, args?: Array<any>): Promise<void>; | ||
enqueueIn(time: number, q: string, func: string, args?: Array<any>, suppressDuplicateTaskError?: boolean): Promise<void>; | ||
/** | ||
@@ -39,0 +39,0 @@ * - queues is an Array with the names of all your queues |
@@ -88,5 +88,5 @@ "use strict"; | ||
*/ | ||
async enqueueIn(time, q, func, args = []) { | ||
async enqueueIn(time, q, func, args = [], suppressDuplicateTaskError = false) { | ||
const timestamp = new Date().getTime() + parseInt(time.toString(), 10); | ||
return this.enqueueAt(timestamp, q, func, args); | ||
return this.enqueueAt(timestamp, q, func, args, suppressDuplicateTaskError); | ||
} | ||
@@ -93,0 +93,0 @@ /** |
@@ -6,3 +6,3 @@ { | ||
"license": "Apache-2.0", | ||
"version": "8.0.2", | ||
"version": "8.0.3", | ||
"homepage": "http://github.com/actionhero/node-resque", | ||
@@ -9,0 +9,0 @@ "repository": { |
@@ -130,6 +130,7 @@ import { EventEmitter } from "events"; | ||
func: string, | ||
args: Array<any> = [] | ||
args: Array<any> = [], | ||
suppressDuplicateTaskError = false | ||
) { | ||
const timestamp = new Date().getTime() + parseInt(time.toString(), 10); | ||
return this.enqueueAt(timestamp, q, func, args); | ||
return this.enqueueAt(timestamp, q, func, args, suppressDuplicateTaskError); | ||
} | ||
@@ -136,0 +137,0 @@ |
666605
8100