Comparing version 5.0.0-beta1 to 5.0.0-beta2
@@ -18,4 +18,2 @@ /// <reference types="node" /> | ||
process(topics?: string[]): Promise<void>; | ||
pause(): Promise<void>; | ||
resume(): Promise<void>; | ||
createQueue({ topic, visibilityTimeout, maxsize, }: CreateRedisTopic): Promise<void>; | ||
@@ -22,0 +20,0 @@ disconnect(): Promise<void>; |
@@ -115,2 +115,3 @@ "use strict"; | ||
this.logger.debug(`paused processing`); | ||
loop(); | ||
return; | ||
@@ -125,4 +126,2 @@ } | ||
} | ||
async pause() { } | ||
async resume() { } | ||
async createQueue({ topic, visibilityTimeout = 604800, maxsize = -1, }) { | ||
@@ -129,0 +128,0 @@ this.logger.debug(`creating queue ${topic}`); |
{ | ||
"name": "steveo", | ||
"version": "5.0.0-beta1", | ||
"version": "5.0.0-beta2", | ||
"description": "A Task Pub/Sub Background processing library", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
92833
1945