diff --git a/index.js b/index.js index ad52162..6811623 100644 --- a/index.js +++ b/index.js @@ -10,10 +10,21 @@ const config = require('komodo-sdk/config'); global.KOMODO_LOG_LABEL = `KOMODO-CENTER@${config.name || 'HTTPGETX'}`; process.title = global.KOMODO_LOG_LABEL; -/* -const matrix = require('komodo-sdk/matrix'); +const cluster = require('cluster'); +const logger = require('komodo-sdk/logger'); -matrix.NODE_ENV = process.env.NODE_ENV; -*/ +if (config.cluster && cluster.isMaster) { + logger.info(`Running on cluster mode. Master ${process.pid} is running`); -require('./lib/listener-partner'); + // eslint-disable-next-line no-plusplus + for (let i = 0; i < config.cluster; i++) { + cluster.fork(); + } +} else { + if (config.cluster) { + logger.info(`Worker ${process.pid} started`); + } + + // eslint-disable-next-line global-require + require('./lib/listener-partner'); +}