var Redis    = require("redis"),
    Queue    = require("../index"),
    ZK       = require("zkjs"),
    zk       = new ZK({hosts: ["api.yongwo.de:2181"], root: "/pew-pew", timeout: 2000}),
    redisOne = Redis.createClient(6379, "127.0.0.1", {retry_max_delay: 1000}),
    redisTwo = Redis.createClient(6380, "127.0.0.1", {retry_max_delay: 1000}),
    queue    = new Queue([redisOne, redisTwo], zk, "woo"); // "woo" is a queue key
 
// error event is triggered for recoverable errors,
// if error is unrecoverable, you'll receive error in callback
queue.on("error", function(error) {
    console.log("Got warning", error);
});
 
// we are ready to start
queue.on("ready", function() {
    // push item to queue
    queue.push("pew", function(error) {
        if (error) {
            // push failed on every redis server
            throw error;
        }
    });
 
    // let's try to get something for 5 times (second argument)
    queue.pop(function(error, item, remove) {
        if (error) {
            // no redis servers are alive
            // or zookeeper is down
            // damn!
            throw error;
        }
 
        if (item) {
            // we got item and it's locked for us!
            console.log("Look what I've got:", item);
 
            // remove item after all work is done
            remove(function() {
                // no error if everything is down,
                // "error" event will be emitter
                // and item can be processed by another worker
                console.log("Item removed!");
            });
        }
    }, 5);
});