From 19947b3b607e155f682aabe8f062db4f6b58f43b Mon Sep 17 00:00:00 2001 From: luin Date: Wed, 19 Sep 2018 09:32:26 +0800 Subject: [PATCH] add actions for subscriber --- lib/cluster/index.js | 3 +++ 1 file changed, 3 insertions(+) diff --git a/lib/cluster/index.js b/lib/cluster/index.js index f7158db9..45960c2b 100644 --- a/lib/cluster/index.js +++ b/lib/cluster/index.js @@ -414,6 +414,9 @@ Cluster.prototype.refreshSlotsCache = function (callback) { debug('getting slot cache from %s', key); if (_this.subscriber === node) { debug('skipping because the node is the subscriber'); + lastNodeError = new Error('Node is the subscriber'); + tryNode(index + 1); + return; } _this.getInfoFromNode(node, function (err) { if (_this.status === 'end') {