Updated Async library to get unsaturated event handled.

Fixed minor bugs. Call new poll only after the task gets queued (only this way we can make sure that the queue is not saturated already).

Author: MichaelKovalchuk

lib/poller.js

@@ -27,16 +27,20 @@ var Poller = exports.Poller = function(config, swfClient) {
    this.logger = config.logger || console;
    delete config.logger
    this.taskLimitation = config.taskLimitation || Number.MAX_SAFE_INTEGER;
+   delete config.taskLimitation
    this.taskQueue = async.queue(function(queueFunc, callback){
-    queueFunc(callback);
+     if (!self.pause_poller) {
+       self.poll();
+     }
+     queueFunc(callback);
    }, this.taskLimitation);
-   this.taskQueue.drain = function(){
-    if (this.pause_poller) {
+   this.taskQueue.unsaturated = function(){
+    if (self.pause_poller) {
       self.resume();
     }
    };
    this.taskQueue.saturated = function(){
-    if (!this.pause_poller) {
+    if (!self.pause_poller) {
       self.pause();
     }
    };
@@ -117,7 +121,7 @@ Poller.prototype.stop = function () {
 Poller.prototype.poll = function () {
 
    if (this.stop_poller || this.pause_poller) {
-      this.logger.info('Poller stopped, shutting down...');
+      this.logger.info('Poller stopped or paused');
       return;
    }
 
@@ -162,7 +166,6 @@ Poller.prototype.poll = function () {
          return;
       }
       _this._onNewTask(result);
-      _this.poll();
    });
 
 };

package.json

@@ -21,7 +21,7 @@
     "url": "http://github.com/neyric/aws-swf.git"
   },
   "dependencies": {
-    "async": "^1.5.0",
+    "async": "^2.1.2",
     "aws-sdk": "^2.2.22",
     "lodash": "^3.10.1"
   },