fix(consumer): 消息超时时程序崩溃问题

Author: leizongmin

example/producer.js

@@ -14,7 +14,8 @@ const p = new Producer({
     host: '127.0.0.1',
     port: 6379,
     prefix: 'example:',
-  }
+  },
+  maxAge: 2,
 });
 
 p.on('start', () => {

lib/consumer.js

@@ -77,14 +77,14 @@ class Consumer extends EventEmitter {
           const info = utils.splitString(ret, ',', 4);
 
           const expire = Number(info[2]);
-          if (expire > 0 && expire < utils.secondTimestamp()) {
-            return reply(producerName, msgId, 'e', 'message expired', ret);
-          }
-
           const producerName = info[0];
           const msgId = info[1];
           const data = info[3];
 
+          if (expire > 0 && expire < utils.secondTimestamp()) {
+            return reply(producerName, msgId, 'e', 'message expired', ret);
+          }
+
           const msg = new Message(producerName, msgId, expire, data, ret);
           this._processing.set(producerName + ':' + msgId, true);
           msgHandler(msg);