fix(consumer): lrem -1

Author: leizongmin

lib/consumer.js

@@ -104,7 +104,7 @@ class Consumer extends EventEmitter {
       this._redisPub.publish(callbackKey, callbackData);
       this._debug('reply: %s <- %s', callbackKey, callbackData);
 
-      this._redisPub.lrem(this._processingQueueKey, 0, originData);
+      this._redisPub.lrem(this._processingQueueKey, -1, originData);
       this._debug('delete msg: %s :: %s', this._processingQueueKey, originData);
 
       this._processing.delete(producerName + ':' + msgId);