Complete Gearman example

gearman-complete

<?php
// client
$gmc= new GearmanClient();
$gmc->addServer();

$gmc->setExceptionCallback(function(GearmanTask $task) {
    $m = $task->data();

    echo "Exception: {$m}\n";

    return GEARMAN_WORK_EXCEPTION;
});

$workload = array(
    'member_id' => 12345,
    'device_token' => 'abcdefg',
    'message' => 'test message',
    'scheduled_time' => date('c')
);

$gmc->do('push_notification', json_encode($workload));
?>

<?php
// worker

$gmw = new GearmanWorker();
$gmw->addServer();

$gmw->addFunction('push_notification', function(GearmanJob $job) {
    $workload = json_decode($job->workload());

    var_dump($workload);
});

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