fix: 初始化实例时检查options

Author: leizongmin

lib/consumer.js

@@ -27,6 +27,7 @@ class Consumer extends EventEmitter {
   constructor(options) {
     super();
 
+    options = options || {};
     if (!options.queue) throw new Error('missing queue name');
 
     this._redisPull = utils.createRedisClient(options.redis);

lib/monitor.js

@@ -72,6 +72,8 @@ class Monitor extends EventEmitter {
   constructor(options) {
     super();
 
+    options = options || {};
+
     this._redis = utils.createRedisClient(options.redis);
     this.name = utils.generateClientId('monitor');
     this._redisPrefix = (options.redis && options.redis.prefix) || '';

lib/producer.js

@@ -27,6 +27,7 @@ class Producer extends EventEmitter {
   constructor(options) {
     super();
 
+    options = options || {};
     if (!options.queue) throw new Error('missing queue name');
 
     this._redis = utils.createRedisClient(options.redis);
@@ -47,12 +48,12 @@ class Producer extends EventEmitter {
 
     const callbackKey = utils.getCallbackKey(this._redisPrefix, this.queue, this.name);
     this._redisSub.subscribe(callbackKey, (channel, count) => {
-      this._debug('on subscribe: chennel=%s, count=%s', channel, count);
+      this._debug('on subscribe: channel=%s, count=%s', channel, count);
       this.emit('start');
     });
 
-    this._redisSub.on('message', (chennel, message) => {
-      this._debug('on reply: %s -> %s', chennel, message);
+    this._redisSub.on('message', (channel, message) => {
+      this._debug('on reply: %s -> %s', channel, message);
 
       // msg: success => id,s,data    error => id,e,data
       const info = utils.splitString(message, ',', 3);