Merge pull request #2 from sloops77/011

011

Author: sloops77

dist/index.js

@@ -19,20 +19,20 @@ class RedisExclusiveTask {
 
     extendAndRun(lock) {
         return lock.extend(this.interval * 2).then(() => this.task()).delay(this.interval).then(() => this.extendAndRun(lock)) // recurse
-        .catch(() => this.log.info(`@RedisExclusiveTask(${ this.taskName }): Unable to extend lock`)).finally(() => this.log.warn(`@RedisExclusiveTask(${ this.taskName }): Leaving extendAndUpdate`));
+        .catch(() => RedisExclusiveTask.log.info(`@RedisExclusiveTask(${ this.taskName }): Unable to extend lock`)).finally(() => RedisExclusiveTask.log.warn(`@RedisExclusiveTask(${ this.taskName }): Leaving extendAndUpdate`));
         // only on error bail out
     }
 
     lockAndRun() {
-        return this.redlock.lock(`${ this.taskName }:run`, this.interval * 2).then(lock => {
-            log.info(`@RedisExclusiveTask(${ this.taskName }): I have the lock!`);
+        return RedisExclusiveTask.redlockInstance.lock(`${ this.taskName }:run`, this.interval * 2).then(lock => {
+            RedisExclusiveTask.log.info(`@RedisExclusiveTask(${ this.taskName }): I have the lock!`);
             return this.extendAndRun(lock);
         }).catch(() => {});
     }
 
     static configure(clients, log = console) {
         this.log = log;
-        this.redlock = new _redlock2.default(clients, { retryCount: 0 });
+        this.redlockInstance = new _redlock2.default(clients, { retryCount: 0 });
     }
 
     static run(taskName, task, interval) {

package.json

@@ -1,7 +1,6 @@
 {
   "name": "redis-exclusive-task",
-  "version": "0.1.0",
-  "private": true,
+  "version": "0.1.1",
   "scripts": {
     "build": "babel src/index.js --out-file dist/index.js --presets node6"
   },

src/index.js

@@ -16,23 +16,23 @@ export default class RedisExclusiveTask {
           .then(() => this.task())
           .delay(this.interval)
           .then(() => this.extendAndRun(lock)) // recurse
-          .catch(() => this.log.info(`@RedisExclusiveTask(${this.taskName}): Unable to extend lock`))
-          .finally(() => this.log.warn(`@RedisExclusiveTask(${this.taskName}): Leaving extendAndUpdate`));
+          .catch(() => RedisExclusiveTask.log.info(`@RedisExclusiveTask(${this.taskName}): Unable to extend lock`))
+          .finally(() => RedisExclusiveTask.log.warn(`@RedisExclusiveTask(${this.taskName}): Leaving extendAndUpdate`));
                         // only on error bail out
     }
 
     lockAndRun() {
-        return this.redlock.lock(`${this.taskName}:run`, this.interval * 2)
+        return RedisExclusiveTask.redlockInstance.lock(`${this.taskName}:run`, this.interval * 2)
             .then((lock) => {
-                log.info(`@RedisExclusiveTask(${this.taskName}): I have the lock!`);
+                RedisExclusiveTask.log.info(`@RedisExclusiveTask(${this.taskName}): I have the lock!`);
                 return this.extendAndRun(lock);
             })
             .catch(() => {});
     }
 
     static configure(clients, log = console) {
         this.log = log;
-        this.redlock = new Redlock(clients, { retryCount: 0 });
+        this.redlockInstance = new Redlock(clients, { retryCount: 0 });
     }
 
     static run(taskName, task, interval) {