Equip\Queue\Queue

Complexity

Total Complexity

3

Size/Duplication

Total Lines	37
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	4
Bugs	1	Features	3

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	2
A	add()	0	7	1

<?php

namespace Equip\Queue;

use Equip\Queue\Driver\DriverInterface;
use Equip\Queue\Serializer\JsonSerializer;
use Equip\Queue\Serializer\MessageSerializerInterface;

class Queue
{
    /**
     * @var DriverInterface
     */
    private $driver;

    /**
     * @var MessageSerializerInterface
     */
    private $serializer;

    /**
     * @param DriverInterface $driver
     * @param MessageSerializerInterface $serializer
     */
    public function __construct(DriverInterface $driver, MessageSerializerInterface $serializer = null)
    {
        $this->driver = $driver;
        $this->serializer = $serializer ?: new JsonSerializer;
    }

    /**
     * Adds a message to the queue
     *
     * @param Message $message
     *
     * @return bool
     */
    public function add(Message $message)
    {
        return $this->driver->push(
            $message->queue(),
            $this->serializer->serialize($message)
        );
    }
}