Gearman worker addTasks example

gearman-worker-addTask.php

// macro.php
<?php

$gmw = new GearmanWorker();

$gmw->addServer();

$gmw->addFunction('macro', function(GearmanJob $job) {
    $gmc = new GearmanClient;

    $gmc->addServer();

    $gmc->setCompleteCallback(function(GearmanTask $task) {
        $h = $task->jobHandle();
        echo "Job '{$h}' complete", PHP_EOL;
    });

    $gmc->setFailCallback(function(GearmanTask $task) {
        $h = $task->jobHandle();
        echo "Job '{$h}' failed", PHP_EOL;
    });

    $gmc->addTask('micro', 'pass');
    $gmc->addTask('micro', 'pass');
    $gmc->addTask('micro', 'pass');
    $gmc->addTask('micro', 'fail');
    $gmc->addTask('micro', 'fail');
    $gmc->addTask('micro', 'fail');


    $gmc->runTasks();

});

while ($gmw->work());
?>

// micro.php
<?php

$gmw = new GearmanWorker;

$gmw->addServer();

$gmw->addFunction('micro', function(GearmanJob $job) {
    if ($job->workload() == 'fail') {
        $job->sendFail();
    } else {
        $job->sendComplete('complete');
    }
});

while ($gmw->work());
?>

// cli
gearman -f macro -s

So the companion client to the "echo" worker above would have to register a setDataCallback method to receive the object sent through the sendData call, right?

Similarly, the worker should call sendComplete if the client is expecting something via setCompleteCallback.

I don't do many callbacks with Gearman, but the manual really failed to make the connection for me. Thanks!