QueueManager.php

<?php

namespace Wowo\QueueBundle;

/**
 * Proxies queue implementation
 *
 * @uses QueueImplementationInterface
 * @package default
 * @version $id$
 * @copyright
 * @author Wojciech Sznapka <wojciech@sznapka.pl>
 * @license
 */
class QueueManager
{
    /**
     * Concrete implementation of queue mechanizm
     */
    protected $implementation;

    /**
     * Default tube
     */
    protected $tube;

    /**
     * The constructor, gets implementation as a param
     *
     * @param QueueImplementationInterface $implementation
     */
    public function __construct(QueueImplementationInterface $implementation)
    {
        $this->implementation = $implementation;
    }

    /**
     * Sset tube
     *
     * @param string $tube tube
     */
    public function setTube($tube)
    {
        $this->tube = $tube;
    }

    /**
     * Gets tube
     *
     * @return string
     */
    public function getTube()
    {
        return $this->tube;
    }

    public function put($job, $priority = null, $delay = null, $ttr = null)
    {
        return $this->implementation->put($this->tube, $job, $priority, $delay, $ttr);
    }

    public function release($job, $priority = null, $delay = null)
    {
        return $this->implementation->release($this->tube, $job, $priority, $delay);
    }

    public function get($secondsToWait = null)
    {
        return $this->implementation->get($this->tube, $secondsToWait);
    }

    public function delete($implementationSpecyficJobObject)
    {
        return $this->implementation->delete($implementationSpecyficJobObject);
    }
}