Pheanstalkd_putTask

gistfile1.aw

<?php
function putTask(
    $data, 
    $priority, 
    $delay = 0, 
    $tube = 'default', 
    $canIgnore = false
) {
    $taskInfo = array('task'      => $data,
                      '_queuedAt' => time(),
                      '_ignorable'=> $canIgnore,
                );
    $json = json_encode($taskInfo);
    $this->pheanstalk
         ->useTube($tube)
         ->put($json, $priority, $delay, self::DEFAULT_TTR);
}