|
|
|
@ -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 { |
|
|
|
|