Browse Source

corrected consume and reliable fetch when hitting end of queue

pull/6/head
Matthias Goetzke 12 years ago
parent
commit
588b48ed3c
2 changed files with 6 additions and 5 deletions
  1. +1
    -0
      lib/kestrelClient.js
  2. +5
    -5
      lib/kestrelConsumer.js

+ 1
- 0
lib/kestrelClient.js View File

@ -123,6 +123,7 @@ function _handleData(data, self){
if( data == 'END\r\n' ){ if( data == 'END\r\n' ){
self._openConnection = null;
self.emit('empty', null); self.emit('empty', null);
} }


+ 5
- 5
lib/kestrelConsumer.js View File

@ -37,12 +37,12 @@ function connectToClient(self){
self.consume(consumeOptions,consumeCallback); self.consume(consumeOptions,consumeCallback);
}); });
} else { } else {
self._consumeNextMessage();
self._getNextMessage();
} }
}); });
} else { } else {
self._callback(message); self._callback(message);
self._consumeNextMessage();
self._getNextMessage();
} }
} }
@ -50,7 +50,7 @@ function connectToClient(self){
}); });
client.on('empty', function(){ client.on('empty', function(){
self.get(self._timeout);
self._getNextMessage();
}); });
return client; return client;
@ -88,10 +88,10 @@ consumer.prototype.consume = function( options, callback ){
this._callback = callback; this._callback = callback;
this._consume = options; this._consume = options;
this._consumeNextMessage();
this._getNextMessage();
}; };
consumer.prototype._consumeNextMessage = function(){
consumer.prototype._getNextMessage = function(){
if(this._consume.reliable){ if(this._consume.reliable){
this.getNextOpen(this._timeout); this.getNextOpen(this._timeout);
} else { } else {


Loading…
Cancel
Save