Bernard\Queue\AbstractQueue

Complexity

Total Complexity

8

Size/Duplication

Total Lines	66
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

7 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	close()	0	4	1
A	acknowledge()	0	4	1
A	errorIfClosed()	0	6	2
A	getOptions()	0	4	1
A	setOptions()	0	4	1
A	__toString()	0	4	1

<?php

namespace Bernard\Queue;

use Bernard\Envelope;
use Bernard\Exception\InvalidOperationException;

/**
 * @package Bernard
 */
abstract class AbstractQueue implements \Bernard\Queue
{
    protected $closed;
    protected $name;
    protected $options = [];

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

    /**
     * {@inheritdoc}
     */
    public function close()
    {
        $this->closed = true;
    }

    /**
     * By Default this is not implemented. For Memory queues it does not make sense.
     *
     * {@inheritdoc}
     */
    public function acknowledge(Envelope $envelope)
    {
        $this->errorIfClosed();
    }

    /**
     * @throws InvalidOperationException
     */
    protected function errorIfClosed()
    {
        if ($this->closed) {
            throw new InvalidOperationException(sprintf('Queue "%s" is closed.', $this->name));
        }
    }

    /**
     * {@inheritdoc}
     */
    public function getOptions()
    {
        return $this->options;
    }

    /**
     * {@inheritdoc}
     */
    public function setOptions(array $options)
    {
        $this->options = $options;
    }

    /**
     * {@inheritdoc}
     */
    public function __toString()
    {
        return (string) $this->name;
    }
}