Fix issue in Client where this should be self (#708)

Signed-off-by: Michael Haan <haanmd@gmail.com>
SOHU-Co · Jul 13, 2017 · 3fecae2 · 3fecae2
1 parent b483e5c
commit 3fecae2
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/client.js b/lib/client.js
@@ -279,7 +279,7 @@ Client.prototype.sendOffsetRequest = function (payloads, cb) {
   this.send(payloads, encoder, decoder, cb);
 };
 
-Client.prototype.refreshBrokerMetadata = function () {};
+Client.prototype.refreshBrokerMetadata = function () { };
 
 Client.prototype.sendGroupRequest = function (encode, decode, requestArgs) {
   requestArgs = _.values(requestArgs);
@@ -538,7 +538,7 @@ Client.prototype.send = function (payloads, encoder, decoder, cb) {
       // check payloads again
       payloads = self.checkMetadatas(_payloads);
       if (payloads[1].length) {
-        this.refreshBrokerMetadata();
+        self.refreshBrokerMetadata();
         return cb(new errors.BrokerNotAvailableError('Could not find the leader'));
       }