Wandu\Q\Adapter\BeanstalkdAdapter

Complexity

Total Complexity

4

Size/Duplication

Total Lines	33
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	enqueue()	0	4	1
A	dequeue()	0	8	2

<?php
namespace Wandu\Q\Adapter;

use Pheanstalk\PheanstalkInterface;
use Wandu\Q\Contracts\AdapterInterface;
use Wandu\Q\Contracts\SerializerInterface;
use Wandu\Q\Job\BeanstalkdJob;

class BeanstalkdAdapter implements AdapterInterface
{
    /** @var \Pheanstalk\PheanstalkInterface */
    protected $client;

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

    /**
     * {@inheritdoc}
     */
    public function enqueue(SerializerInterface $serializer, $payload)
    {
        $this->client->put($serializer->serialize($payload));
    }

    /**
     * {@inheritdoc}
     */
    public function dequeue(SerializerInterface $serializer)
    {
        $job = $this->client->reserve();
        if ($job) {
            return new BeanstalkdJob($this->client, $job, $serializer);
        }
        return null;
    }
}