Rediska Worker/Queue Pair for Recurring Tasks

Jeffe.php

<?php
$options = array('namespace' => 'WorkerProcess_',
'servers' => array(array('host' => '127.0.0.1', 'port' => 6380)));
/* el Jeffe */
$redis = new Rediska($options);
while (true) {
    $first_url = $redis->popFromListBlocking(SRC_QUEUE, 0, SRC_QUEUE);
    if($first_url){
        $redis->appendToList(WORK_QUEUE, $first_url);
    }
    while (true) {
        $next_url = $redis->popFromListBlocking(SRC_QUEUE, 0, SRC_QUEUE);
        if ($next_url != $first_url) {
            $redis->appendToList(WORK_QUEUE, $next_url);
        } else {
            break;
        }
    }
    sleep(SLEEP_INTERVAL);
}

Paisano.php

<?php
$options = array('namespace' => 'WorkerProcess_',
'servers' => array(array('host' => '127.0.0.1', 'port' => 6380)));
/* el paisano */
$redis = new Rediska($options);
while(true){
    $url = $redis->popFromListBlocking(WORK_QUEUE, 0);
    $taskResult = someTask($url);
    if($taskResult){
        echo 'success', PHP_EOL;
    } else {
        echo 'failure', PHP_EOL;
    }
}