Bernard\Driver\PheanstalkDriver

Complexity

Total Complexity

12

Size/Duplication

Total Lines	111
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes	13
Bugs	1	Features	3

11 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	listQueues()	0	4	1
A	countMessages()	0	6	1
A	createQueue()	0	3	1
A	pushMessage()	0	12	1
A	popMessage()	0	8	2
A	acknowledgeMessage()	0	4	1
A	peekQueue()	0	4	1
A	removeQueue()	0	3	1
A	info()	0	7	1
A	configurePushOptions()	0	8	1

<?php

namespace Bernard\Driver;

use Pheanstalk\PheanstalkInterface;
use Symfony\Component\OptionsResolver\OptionsResolver;

/**
 * Implements a Driver for use with https://github.com/pda/pheanstalk
 *
 * @package Bernard
 */
class PheanstalkDriver extends AbstractDriver
{
    protected $pheanstalk;

    /**
     * @param PheanstalkInterface $pheanstalk
     */
    public function __construct(PheanstalkInterface $pheanstalk)
    {
        $this->pheanstalk = $pheanstalk;
    }

    /**
     * {@inheritdoc}
     */
    public function listQueues()
    {
        return $this->pheanstalk->listTubes();
    }

    /**
     * {@inheritdoc}
     */
    public function createQueue($queueName, array $options = [])
    {
    }

    /**
     * {@inheritdoc}
     */
    public function countMessages($queueName)
    {
        $stats = $this->pheanstalk->statsTube($queueName);

        return $stats['current-jobs-ready'];
    }

    /**
     * {@inheritdoc}
     */
    public function pushMessage($queueName, $message, array $options = [])
    {
        $options = $this->validatePushOptions($options);

        $this->pheanstalk->putInTube(
            $queueName,
            $message,
            $options['priority'],
            $options['delay'],
            $options['ttr']
        );
    }

    /**
     * {@inheritdoc}
     */
    public function popMessage($queueName, $duration = 5)
    {
        if ($job = $this->pheanstalk->reserveFromTube($queueName, $duration)) {
            return [$job->getData(), $job];
        }

        return array(null, null);
    }

    /**
     * {@inheritdoc}
     */
    public function acknowledgeMessage($queueName, $receipt)
    {
        $this->pheanstalk->delete($receipt);
    }

    /**
     * {@inheritdoc}
     */
    public function peekQueue($queueName, $index = 0, $limit = 20)
    {
        return [];
    }

    /**
     * {@inheritdoc}
     */
    public function removeQueue($queueName)
    {
    }

    /**
     * {@inheritdoc}
     */
    public function info()
    {
        return $this->pheanstalk
            ->stats()
            ->getArrayCopy()
        ;
    }

    /**
     * {@inheritdoc}
     */
    public function configurePushOptions(OptionsResolver $resolver)
    {
        $resolver->setDefaults(array(
            'priority' => PheanstalkInterface::DEFAULT_PRIORITY,
            'delay' => PheanstalkInterface::DEFAULT_DELAY,
            'ttr' => PheanstalkInterface::DEFAULT_TTR,
        ));
    }
}