From 019ba5915a534187b6b06238bff6c09d244aa11c Mon Sep 17 00:00:00 2001 From: Simen Brekken Date: Mon, 7 Mar 2016 08:12:11 +0100 Subject: [PATCH] Fix spelling of deferred shut down variable name --- src/lib/queue_worker.js | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/lib/queue_worker.js b/src/lib/queue_worker.js index aed7993..3a03d41 100644 --- a/src/lib/queue_worker.js +++ b/src/lib/queue_worker.js @@ -47,7 +47,7 @@ function QueueWorker(tasksRef, processId, sanitize, suppressStack, processingFun } self.processId = processId + ':' + uuid.v4(); - self.shutdownDeffered = null; + self.shutdownDeferred = null; self.processingFunction = processingFunction; self.expiryTimeouts = {}; @@ -408,11 +408,11 @@ QueueWorker.prototype._tryToProcess = function(nextTaskRef, deferred) { } if (!self.busy) { - if (!_.isNull(self.shutdownDeffered)) { + if (!_.isNull(self.shutdownDeferred)) { deferred.reject(new Error('Shutting down - can no longer process new tasks')); self.setTaskSpec(null); logger.debug(self._getLogEntry('finished shutdown')); - self.shutdownDeffered.resolve(); + self.shutdownDeferred.resolve(); } else { nextTaskRef.transaction(function(task) { /* istanbul ignore if */ @@ -729,16 +729,16 @@ QueueWorker.prototype.shutdown = function() { logger.debug(self._getLogEntry('shutting down')); // Set the global shutdown deferred promise, which signals we're shutting down - self.shutdownDeffered = RSVP.defer(); + self.shutdownDeferred = RSVP.defer(); // We can report success immediately if we're not busy if (!self.busy) { self.setTaskSpec(null); logger.debug(self._getLogEntry('finished shutdown')); - self.shutdownDeffered.resolve(); + self.shutdownDeferred.resolve(); } - return self.shutdownDeffered.promise; + return self.shutdownDeferred.promise; }; module.exports = QueueWorker;