Fix method name

Arc-io · Jan 15, 2021 · 5105438 · 5105438
1 parent ea86804
commit 5105438
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/index.js b/index.js
@@ -126,13 +126,13 @@ module.exports.attach = function (broker, options) {
     instanceIpFamily: options.instanceIpFamily || 'IPv4'
   };
 
-  let emitsccWorkerJoinCluster = async () => {
+  let emitSCCWorkerJoinCluster = async () => {
     let data;
     try {
       data = await stateSocket.invoke('sccWorkerJoinCluster', sccWorkerStateData);
     } catch (error) {
       stateSocket.emit('error', {error});
-      setTimeout(emitsccWorkerJoinCluster, retryDelay);
+      setTimeout(emitSCCWorkerJoinCluster, retryDelay);
       return;
     }
     resetBrokersSnapshotTime();
@@ -143,7 +143,7 @@ module.exports.attach = function (broker, options) {
 
   (async () => {
     for await (let event of stateSocket.listener('connect')) {
-      emitsccWorkerJoinCluster();
+      emitSCCWorkerJoinCluster();
     }
   })();