Comparing version 5.1.5 to 5.1.6
@@ -147,4 +147,3 @@ /** | ||
} | ||
async pause(pause) { | ||
const client = await this.queue.client; | ||
pauseArgs(pause) { | ||
let src = 'wait', dst = 'paused'; | ||
@@ -157,4 +156,10 @@ if (!pause) { | ||
keys.push(this.queue.keys.events, this.queue.keys.delayed, this.queue.keys.marker); | ||
return client.pause(keys.concat([pause ? 'paused' : 'resumed'])); | ||
const args = [pause ? 'paused' : 'resumed']; | ||
return keys.concat(args); | ||
} | ||
async pause(pause) { | ||
const client = await this.queue.client; | ||
const args = this.pauseArgs(pause); | ||
return client.pause(args); | ||
} | ||
removeRepeatableArgs(repeatJobId, repeatJobKey) { | ||
@@ -690,2 +695,3 @@ const queueKeys = this.queue.keys; | ||
this.queue.keys.prioritized, | ||
this.queue.keys.marker, | ||
this.queue.keys.events, | ||
@@ -692,0 +698,0 @@ ]; |
@@ -19,3 +19,3 @@ "use strict"; | ||
tslib_1.__exportStar(require("./isJobInList-1"), exports); | ||
tslib_1.__exportStar(require("./moveJobFromActiveToWait-9"), exports); | ||
tslib_1.__exportStar(require("./moveJobFromActiveToWait-10"), exports); | ||
tslib_1.__exportStar(require("./moveJobsToWait-7"), exports); | ||
@@ -22,0 +22,0 @@ tslib_1.__exportStar(require("./moveStalledJobsToWait-9"), exports); |
@@ -19,2 +19,3 @@ /** | ||
addJob(client: RedisClient, job: JobJson, opts: RedisJobOptions, jobId: string, parentOpts?: ParentOpts): Promise<string>; | ||
protected pauseArgs(pause: boolean): (string | number)[]; | ||
pause(pause: boolean): Promise<void>; | ||
@@ -21,0 +22,0 @@ private removeRepeatableArgs; |
@@ -145,4 +145,3 @@ /** | ||
} | ||
async pause(pause) { | ||
const client = await this.queue.client; | ||
pauseArgs(pause) { | ||
let src = 'wait', dst = 'paused'; | ||
@@ -155,4 +154,10 @@ if (!pause) { | ||
keys.push(this.queue.keys.events, this.queue.keys.delayed, this.queue.keys.marker); | ||
return client.pause(keys.concat([pause ? 'paused' : 'resumed'])); | ||
const args = [pause ? 'paused' : 'resumed']; | ||
return keys.concat(args); | ||
} | ||
async pause(pause) { | ||
const client = await this.queue.client; | ||
const args = this.pauseArgs(pause); | ||
return client.pause(args); | ||
} | ||
removeRepeatableArgs(repeatJobId, repeatJobKey) { | ||
@@ -688,2 +693,3 @@ const queueKeys = this.queue.keys; | ||
this.queue.keys.prioritized, | ||
this.queue.keys.marker, | ||
this.queue.keys.events, | ||
@@ -690,0 +696,0 @@ ]; |
@@ -16,3 +16,3 @@ export * from './addDelayedJob-6'; | ||
export * from './isJobInList-1'; | ||
export * from './moveJobFromActiveToWait-9'; | ||
export * from './moveJobFromActiveToWait-10'; | ||
export * from './moveJobsToWait-7'; | ||
@@ -19,0 +19,0 @@ export * from './moveStalledJobsToWait-9'; |
@@ -16,3 +16,3 @@ export * from './addDelayedJob-6'; | ||
export * from './isJobInList-1'; | ||
export * from './moveJobFromActiveToWait-9'; | ||
export * from './moveJobFromActiveToWait-10'; | ||
export * from './moveJobsToWait-7'; | ||
@@ -19,0 +19,0 @@ export * from './moveStalledJobsToWait-9'; |
{ | ||
"name": "bullmq", | ||
"version": "5.1.5", | ||
"version": "5.1.6", | ||
"description": "Queue for messages and jobs based on Redis", | ||
@@ -5,0 +5,0 @@ "homepage": "https://bullmq.io/", |
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
1480174
23260