feat: add restart and rework close/stop/start/restart for #12

Author: piercus

lib/worker.js

@@ -69,7 +69,10 @@ function Worker(options) {
 * @param {function} callback
 */
 Worker.prototype.start = function (cb) {
-	this.updatePool(cb);
+	this.updatePool(err => {
+		this.logger.info('Worker started');
+		cb(err);
+	});
 };
 /**
 * Get a report of the actual situation of the worker
@@ -117,30 +120,39 @@ Worker.prototype.removePooler = function (cb) {
 
 /**
 * Close the worker, this function might take 60 seconds to finish to do step function design
+* remove all the events attached to the worker
 * @param {function} callback
 */
 
 Worker.prototype.close = function (cb) {
-	this.logger.info('Closing the worker ... this might take 60 seconds');
+	this.stop(cb);
+	this.removeAllListeners();
+};
+
+/**
+* Stop the worker
+* But does not remove all the events attached to it
+* NB: worker.concurrency is set to 0
+* @param {function} callback
+*/
+
+Worker.prototype.stop = function (cb) {
+	this.logger.info('Stopping the worker ... this might take 60 seconds');
 	this.concurrency = 0;
 	this.updatePool(err => {
-		this.logger.info('Worker closed');
+		this.logger.info('Worker stopped');
 		cb(err);
 	});
-	this.removeAllListeners();
 };
 
 Worker.prototype.restart = function (cb) {
-	this.logger.info('Restarting the worker ... this might take 60 seconds');
 	const oldConcurrency = this.concurrency;
-	this.concurrency = 0;
-	this.updatePool(() => {
-		this.logger.info('Worker closed');
+	this.stop(err => {
+		if (err) {
+			return cb(err);
+		}
 		this.concurrency = oldConcurrency;
-		this.updatePool(err => {
-			this.logger.info('Worker started');
-			cb(err);
-		});
+		this.start(cb);
 	});
 };