var plan = require('redis-plan')(port, host, option);

plan('your queue name in redis', 'your data to transfer to worker');

plan('your queue name in redis', function(data, next) {
  // u could start handle `data` from queue
  next();
});

var plan = require('../')();
plan.set('maxCount', 100);
plan('parallel', function(data, next) {
  console.log(data);
  setTimeout(next, 3000);
});

var plan = require('../')();
// just a simple for loop
for (var i=0; i<10; i++) {
  plan('parallel', data);
}

plan('async-feedback', function(item, next) {
  asyncMethod(item, function(err) {
    next();
    if (err) 
      plan('error', err.stack);
    else
      plan('success', item);
  });
});

process.on('exit', function() {
  plan.close();
});