GearmanBundle/Dispatcher/GearmanCallbacksDispatcher.php

<?php

/**
 * Gearman Bundle for Symfony2
 *
 * @author Marc Morera <yuhu@mmoreram.com>
 * @since  2013
 */

namespace Mmoreram\GearmanBundle\Dispatcher;

use GearmanTask;

use Mmoreram\GearmanBundle\Dispatcher\Abstracts\AbstractGearmanDispatcher;
use Mmoreram\GearmanBundle\GearmanEvents;
use Mmoreram\GearmanBundle\Event\GearmanClientCallbackCompleteEvent;
use Mmoreram\GearmanBundle\Event\GearmanClientCallbackFailEvent;
use Mmoreram\GearmanBundle\Event\GearmanClientCallbackDataEvent;
use Mmoreram\GearmanBundle\Event\GearmanClientCallbackCreatedEvent;
use Mmoreram\GearmanBundle\Event\GearmanClientCallbackExceptionEvent;
use Mmoreram\GearmanBundle\Event\GearmanClientCallbackStatusEvent;
use Mmoreram\GearmanBundle\Event\GearmanClientCallbackWarningEvent;
use Mmoreram\GearmanBundle\Event\GearmanClientCallbackWorkloadEvent;

/**
 * Gearman callbacks
 *
 * @author Marc Morera <yuhu@mmoreram.com>
 */
class GearmanCallbacksDispatcher extends AbstractGearmanDispatcher
{
    /**
     * Assign all GearmanClient callbacks as Symfony2 events
     *
     * @param \GearmanClient $gearmanClient Gearman client
     *
     * @return GearmanCallbacks self Object
     */
    public function assignTaskCallbacks(\GearmanClient $gearmanClient)
    {
        $gearmanClient->setCompleteCallback(array($this, 'assignCompleteCallback'));
        $gearmanClient->setFailCallback(array($this, 'assignFailCallback'));
        $gearmanClient->setDataCallback(array($this, 'assignDataCallback'));
        $gearmanClient->setCreatedCallback(array($this, 'assignCreatedCallback'));
        $gearmanClient->setExceptionCallback(array($this, 'assignExceptionCallback'));
        $gearmanClient->setStatusCallback(array($this, 'assignStatusCallback'));
        $gearmanClient->setWarningCallback(array($this, 'assignWarningCallback'));
        $gearmanClient->setWorkloadCallback(array($this, 'assignWorkloadCallback'));
    }

    /**
     * Assigns CompleteCallback into GearmanTask
     *
     * @param GearmanTask $gearmanTask Gearman Task
     *
     * @see http://www.php.net/manual/en/gearmanclient.setcompletecallback.php
     */
    public function assignCompleteCallback(GearmanTask $gearmanTask)
    {

        $event = new GearmanClientCallbackCompleteEvent($gearmanTask);
        $this->eventDispatcher->dispatch(GearmanEvents::GEARMAN_CLIENT_CALLBACK_COMPLETE, $event);
    }

    /**
     * Assigns FailCallback into GearmanTask
     *
     * @param GearmanTask $gearmanTask Gearman Task
     *
     * @see http://www.php.net/manual/en/gearmanclient.setfailcallback.php
     */
    public function assignFailCallback(GearmanTask $gearmanTask)
    {

        $event = new GearmanClientCallbackFailEvent($gearmanTask);
        $this->eventDispatcher->dispatch(GearmanEvents::GEARMAN_CLIENT_CALLBACK_FAIL, $event);
    }

    /**
     * Assigns DataCallback into GearmanTask
     *
     * @param GearmanTask $gearmanTask Gearman Task
     *
     * @see http://www.php.net/manual/en/gearmanclient.setdatacallback.php
     */
    public function assignDataCallback(GearmanTask $gearmanTask)
    {

        $event = new GearmanClientCallbackDataEvent($gearmanTask);
        $this->eventDispatcher->dispatch(GearmanEvents::GEARMAN_CLIENT_CALLBACK_DATA, $event);
    }

    /**
     * Assigns CreatedCallback into GearmanTask
     *
     * @param GearmanTask $gearmanTask Gearman task
     *
     * @see http://www.php.net/manual/en/gearmanclient.setcreatedcallback.php
     */
    public function assignCreatedCallback(GearmanTask $gearmanTask)
    {

        $event = new GearmanClientCallbackCreatedEvent($gearmanTask);
        $this->eventDispatcher->dispatch(GearmanEvents::GEARMAN_CLIENT_CALLBACK_CREATED, $event);
    }

    /**
     * Assigns ExceptionCallback into GearmanTask
     *
     * @see http://www.php.net/manual/en/gearmanclient.setexceptioncallback.php
     */
    public function assignExceptionCallback()
    {

        $event = new GearmanClientCallbackExceptionEvent;
        $this->eventDispatcher->dispatch(GearmanEvents::GEARMAN_CLIENT_CALLBACK_EXCEPTION, $event);
    }

    /**
     * Assigns StatusCallback into GearmanTask
     *
     * @param GearmanTask $gearmanTask Gearman Task
     *
     * @see http://www.php.net/manual/en/gearmanclient.setstatuscallback.php
     */
    public function assignStatusCallback(GearmanTask $gearmanTask)
    {

        $event = new GearmanClientCallbackStatusEvent($gearmanTask);
        $this->eventDispatcher->dispatch(GearmanEvents::GEARMAN_CLIENT_CALLBACK_STATUS, $event);
    }

    /**
     * Assigns WarningCallback into GearmanTask
     *
     * @param GearmanTask $gearmanTask Gearman Task
     *
     * @see http://www.php.net/manual/en/gearmanclient.setwarningcallback.php
     */
    public function assignWarningCallback(GearmanTask $gearmanTask)
    {

        $event = new GearmanClientCallbackWarningEvent($gearmanTask);
        $this->eventDispatcher->dispatch(GearmanEvents::GEARMAN_CLIENT_CALLBACK_WARNING, $event);
    }

    /**
     * Assigns WorkloadCallback into GearmanTask
     *
     * @param GearmanTask $gearmanTask Gearman Task
     *
     * @see http://www.php.net/manual/en/gearmanclient.setworkloadcallback.php
     */
    public function assignWorkloadCallback(GearmanTask $gearmanTask)
    {

        $event = new GearmanClientCallbackWorkloadEvent($gearmanTask);
        $this->eventDispatcher->dispatch(GearmanEvents::GEARMAN_CLIENT_CALLBACK_WORKLOAD, $event);
    }
}