Comparing version 5.0.0-beta2.6 to 5.0.0-beta2.7
@@ -146,3 +146,3 @@ "use strict"; | ||
finally { | ||
if (this.paused) { | ||
if (this.steveo.paused) { | ||
this.logger.debug('Consumer paused'); | ||
@@ -238,3 +238,3 @@ return; | ||
} | ||
if (!this.paused) { | ||
if (!this.steveo.paused) { | ||
this.logger.debug('Resuming consumer'); | ||
@@ -241,0 +241,0 @@ this.consumer.consume(1, this.consumeCallback); |
{ | ||
"name": "steveo", | ||
"version": "5.0.0-beta2.6", | ||
"version": "5.0.0-beta2.7", | ||
"description": "A Task Pub/Sub Background processing library", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
94433