Queue + stop ()

Author: Dmitry Ovsyanko

lib/Queue.js

@@ -9,15 +9,19 @@ class Queue extends JobSource {
 
 		super (app, o)
 
-		if ('cron' in o) {
+		if ('cron' in o) this.cron = new Cron (o.cron, {}, () => this.check ())
 
-			const cron = new Cron (o.cron, {}, () => this.check ())
-			
-			this.cron = cron
+		app.once ('finish', () => this.stop ())
 
-			app.once ('finish', () => cron.stop ())
+	}
 
-		}
+	stop () {
+
+		if ('cron' in this) this.cron.stop ()
+
+        this.app.jobSources.delete (this.name)
+
+        this.isStopped = true
 
 	}