From 01adab41745a06198b5b82c74d18907800acf3c6 Mon Sep 17 00:00:00 2001
From: Joe Fleming <joe.fleming@gmail.com>
Date: Tue, 23 May 2017 18:26:24 -0700
Subject: [PATCH] move poller state into this._poller

---
 src/worker.js | 18 ++++++++++--------
 1 file changed, 10 insertions(+), 8 deletions(-)

diff --git a/src/worker.js b/src/worker.js
index e4cb865..d37d4b1 100644
--- a/src/worker.js
+++ b/src/worker.js
@@ -34,14 +34,17 @@ export default class Worker extends events.EventEmitter {
 
     this.debug = (...msg) => debug(...msg, `id: ${this.id}`);
 
-    this._checker = false;
-    this._running = true;
+    this._poller = {
+      timer: false,
+      enabled: true,
+    };
+
     this.debug(`Created worker for job type ${this.jobtype}`);
     this._startJobPolling();
   }
 
   destroy() {
-    this._running = false;
+    this._poller.enabled = false;
     this._stopJobPolling();
   }
 
@@ -247,18 +250,17 @@ export default class Worker extends events.EventEmitter {
   }
 
   _startJobPolling() {
-    if (!this._running) {
+    if (!this._poller.enabled) {
       return;
     }
 
-    this._checker = setInterval(() => {
-      this._getPendingJobs()
-      .then((jobs) => this._claimPendingJobs(jobs));
+    this._poller.timer = setInterval(() => {
+      this._getPendingJobs().then((jobs) => this._claimPendingJobs(jobs));
     } , this.checkInterval);
   }
 
   _stopJobPolling() {
-    clearInterval(this._checker);
+    clearInterval(this._poller.timer);
   }
 
   _claimPendingJobs(jobs) {