Wandu\Q\Queue

Complexity

Total Complexity

6

Size/Duplication

Total Lines	45
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

92.86%

Importance

Changes

0

4 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	2
A	flush()	0	4	1
A	send()	0	4	1
A	receive()	0	6	2

<?php
namespace Wandu\Q;

use Wandu\Q\Contracts\Adapter;
use Wandu\Q\Contracts\Serializer;
use Wandu\Q\Serializer\JsonSerializer;

class Queue
{
    /** @var \Wandu\Q\Contracts\Adapter */
    protected $adapter;

    /** @var \Wandu\Q\Contracts\Serializer */
    protected $serializer;

    /**
     * @param \Wandu\Q\Contracts\Serializer $serializer
     * @param \Wandu\Q\Contracts\Adapter $adapter
     */
    public function __construct(Adapter $adapter, Serializer $serializer = null)
    {
        $this->adapter = $adapter;
        $this->serializer = $serializer ?: new JsonSerializer();
    }

    /**
     * @return void 
     */
    public function flush()
    {
        $this->adapter->flush();
    }

    /**
     * @param mixed $message
     * @return void
     */
    public function send($message)
    {
        $this->adapter->send($this->serializer->serialize($message));
    }

    /**
     * @return \Wandu\Q\Job
     */
    public function receive()
    {
        if ($job = $this->adapter->receive()) {
            return new Job($this->adapter, $this->serializer, $job);
        }
    }
}