Note: I don't consider this code production ready, so use at your own risk. The module only supports PECL Gearman, and if you use it, all your workers must be classes (whereas Gearman Manager on its own supports both worker classes and functions).

This is a Zend Framework 2 module that provides some basic integration between a ZF2 app and Brian Moon's Gearman Manager. Its main feature is to allow worker classes to be setup via. the ZF service locator, which allows app-related dependencies to be passed in.

The module should be installed via. Composer. In addition to adding this module as a dependency you need to add the repository for my forked version of Gearman Manager:

"repositories": [{
    "type": "vcs",
    "url": "https://github.com/tfountain/GearmanManager"
}],

"require": {
    "tfountain/zf-gearman-manager": "dev-master"
}

The forked Gearman Manager is a fork of the main repo's "overhaul" branch, and contains one additional function to override how the worker classes are instantiated.

Instead of being discovered by scanning folders, with this module workers should be specified via. the app config (usually the module.config.php). This done using a gearman_workers array, where the config is the worker alias, and the value is the fully qualified name of the worker class:

'gearman_workers' => array(
    'do-stuff' => 'Application\Worker\DoStuff'
)

Since the workers are loaded by the service manager, you need to add an entry for each one to your service config, either as an invokable in module.config.php:

'service_manager' => array(
    'invokables' => array(
        'Application\Worker\DoStuff' => 'Application\Worker\DoStuff'
    )
)

or as a factory in Module.php:

public function getServiceConfig()
{
    return array(
        'factories' => array(
            'Application\Worker\DoStuff' => function ($sm) {
                // setup and return worker class here
            }
        )
    );
}

namespace Application\Worker;

use ZfGearmanManager\Worker\WorkerInterface;

class DoStuff implements WorkerInterface
{
    public function run($job, &$log)
    {
        // get the string passed to the job
        $workload = $job->workload();

        // do stuff
    }
}

For convenience the module defines a service config entry for the Gearman Client using the key 'GearmanClient' (still TODO: configuration to allow this to use separate servers). So with this, to queue a job (from a controller):

$gmClient = $this->getServiceLocator()->get('GearmanClient');
$gmClient->doBackground('do-stuff', $params); // where $params is the job workload (always a string)

The module includes an example pecl_manager.php which should be coped to a bin folder in your application root. This can then be run with the same command line options as the standard Gearman Manager script.

Since this version does not auto-discover worker classes from a folder, you'll also want to specify -w /dev/null or you'll get an error when Gearman Manager tries to check your worker dir on startup.

You may also want to create an ini configuration file (see Gearman Manager for examples). You can then run this with:

./bin/pecl_manager.php -c config/gearman.ini -w /dev/null

as with Gearman Manager, adding -v increases verbosity of the output (-vv is more verbose, -vvv even more, and so on).