diff --git a/lib/kestrelConsumer.js b/lib/kestrelConsumer.js index d728d5d..fa5d047 100644 --- a/lib/kestrelConsumer.js +++ b/lib/kestrelConsumer.js @@ -30,7 +30,7 @@ var consumer = function( queue, options ){ }); } else { self._callback(message); - self._consumeNextMessage(); + self._consumeNextMessage(); } } @@ -81,7 +81,7 @@ consumer.prototype.consume = function( options, callback ){ this._consumeNextMessage(); }; -consumer.prototype._consumeNextMessage = function(){ +consumer.prototype._consumeNextMessage = function(){ if(this._consume.reliable){ this.getNextOpen(this._timeout); } else {