diff --git a/lib/cluster/index.js b/lib/cluster/index.js index 451dbb3d..7181a7f0 100644 --- a/lib/cluster/index.js +++ b/lib/cluster/index.js @@ -406,8 +406,8 @@ Cluster.prototype.sendCommand = function (command, stream, node) { if (!node && !command.__is_reject_overwritten) { command.__is_reject_overwritten = true; var reject = command.reject; - var partialTry = _.partial(tryConnection, true); command.reject = function (err) { + var partialTry = _.partial(tryConnection, true); _this.handleError(err, ttl, { moved: function (slot, key) { debug('command %s is moved to %s', command.name, key);