TreeHouse\Queue\Amqp\Driver\Amqp\Queue

Complexity

Total Complexity

34

Size/Duplication

Total Lines	280
Duplicated Lines	11.43 %

Coupling/Cohesion

Components	2
Dependencies	2

Test Coverage

Coverage

66.67%

Importance

Changes	2
Bugs	0	Features	1

27 Methods

Rating	Name	Duplication	Size	Complexity
A	getChannel()	0	4	1
A	getConnection()	0	4	1
A	setName()	0	4	1
A	getName()	0	4	1
A	getArgument()	0	4	1
A	getArguments()	0	4	1
A	hasArgument()	0	4	1
A	getFlags()	0	4	1
A	getConsumerTag()	0	4	1
A	declareQueue()	0	4	1
A	bind()	0	4	1
A	unbind()	0	4	1
A	consume()	0	4	1
A	ack()	0	4	1
A	nack()	0	4	1
A	reject()	0	4	1
A	cancel()	0	4	1
A	delete()	0	4	1
A	purge()	0	4	1
A	getDelegate()	0	4	1
A	convertToDelegateFlags()	16	16	4
A	__construct()	0	5	1
A	get()	0	8	2
A	convertFromDelegateFlags()	16	16	4
A	setArgument()	0	4	1
A	setArguments()	0	4	1
A	setFlags()	0	4	1

<?php

namespace TreeHouse\Queue\Amqp\Driver\Amqp;

use TreeHouse\Queue\Amqp\ChannelInterface;
use TreeHouse\Queue\Amqp\QueueInterface;

class Queue implements QueueInterface
{
    /**
     * @var \AMQPQueue
     */
    protected $delegate;

    /**
     * @var ChannelInterface
     */
    protected $channel;

    /**
     * @var array<integer, integer>
     */
    protected static $flagMap = [
        self::NOPARAM => AMQP_NOPARAM,
        self::DURABLE => AMQP_DURABLE,
        self::PASSIVE => AMQP_PASSIVE,
        self::EXCLUSIVE => AMQP_EXCLUSIVE,
        self::AUTODELETE => AMQP_AUTODELETE,
        self::MULTIPLE => AMQP_MULTIPLE,
        self::AUTOACK => AMQP_AUTOACK,
        self::REQUEUE => AMQP_REQUEUE,
        self::IFUNUSED => AMQP_IFUNUSED,
        self::IFEMPTY => AMQP_IFEMPTY,
    ];

    /**
     * @param \AMQPQueue       $delegate
     * @param ChannelInterface $channel
     */
    public function __construct(\AMQPQueue $delegate, ChannelInterface $channel)
    {
        $this->delegate = $delegate;
        $this->channel = $channel;
    }

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

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

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

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

    /**
     * @inheritdoc
     */
    public function setArgument($key, $value)
    {
        return $this->delegate->setArgument($key, $value);
    }

    /**
     * @inheritdoc
     */
    public function setArguments(array $arguments)
    {
        return $this->delegate->setArguments($arguments);
    }

    /**
     * @inheritdoc
     */
    public function getArgument($key)
    {
        return $this->delegate->getArgument($key);
    }

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

    /**
     * @inheritdoc
     */
    public function hasArgument($key)
    {
        return $this->delegate->hasArgument($key);
    }

    /**
     * @inheritDoc
     */
    public function setFlags($flags)
    {
        return $this->delegate->setFlags(self::convertToDelegateFlags($flags));
    }

    /**
     * @inheritdoc
     */
    public function getFlags()
    {
        return self::convertFromDelegateFlags($this->delegate->getFlags());
    }

    /**
     * @inheritdoc
     */
    public function getConsumerTag()
    {
        return $this->delegate->getConsumerTag();

The method getConsumerTag() does not exist on AMQPQueue. Did you maybe mean consume()?

    }

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

    /**
     * @inheritdoc
     */
    public function bind($exchangeName, $routingKey, array $arguments = [])
    {
        return $this->delegate->bind($exchangeName, $routingKey, $arguments);
    }

    /**
     * @inheritdoc
     */
    public function unbind($exchangeName, $routingKey = null, array $arguments = [])
    {
        return $this->delegate->unbind($exchangeName, $routingKey, $arguments);
    }

    /**
     * @inheritdoc
     */
    public function get($flags = null)
    {
        if (false !== $envelope = $this->delegate->get(self::convertToDelegateFlags($flags))) {
            $envelope = new Envelope($envelope);

It seems like $envelope defined by new \TreeHouse\Queue\Amqp\Driver\Amqp\Envelope($envelope) on line 172 can also be of type boolean; however, TreeHouse\Queue\Amqp\Driver\Amqp\Envelope::__construct() does only seem to accept object<AMQPEnvelope>, maybe add an additional type check?

        }

        return $envelope;
    }

    /**
     * @inheritdoc
     */
    public function consume(callable $callback, $flags = null, $consumerTag = null)
    {
        $this->delegate->consume($callback, self::convertToDelegateFlags($flags), $consumerTag);
    }

    /**
     * @inheritdoc
     */
    public function ack($deliveryTag, $flags = null)
    {
        return $this->delegate->ack($deliveryTag, self::convertToDelegateFlags($flags));
    }

    /**
     * @inheritdoc
     */
    public function nack($deliveryTag, $flags = AMQP_NOPARAM)
    {
        $this->delegate->nack($deliveryTag, self::convertToDelegateFlags($flags));
    }

    /**
     * @inheritdoc
     */
    public function reject($deliveryTag, $flags = AMQP_NOPARAM)
    {
        $this->delegate->reject($deliveryTag, self::convertToDelegateFlags($flags));
    }

    /**
     * @inheritdoc
     */
    public function cancel($consumerTag = '')
    {
        return $this->delegate->cancel($consumerTag);
    }

    /**
     * @inheritdoc
     */
    public function delete($flags = null)
    {
        $this->delegate->delete(self::convertToDelegateFlags($flags));
    }

    /**
     * @inheritdoc
     */
    public function purge()
    {
        $this->delegate->purge();
    }

    /**
     * @inheritdoc
     *
     * @return \AMQPQueue
     */
    public function getDelegate()
    {
        return $this->delegate;
    }

    /**
     * @param int|null $flags
     *
     * @return int
     */
    public static function convertToDelegateFlags($flags = null)

This method seems to be duplicated in your project.

    {
        if (null === $flags) {
            return AMQP_NOPARAM;
        }

        $converted = 0;

        foreach (self::$flagMap as $from => $to) {
            if ($flags & $from) {
                $converted |= $to;
            }
        }

        return $converted;
    }

    /**
     * @param int|null $flags
     *
     * @return int
     */
    public static function convertFromDelegateFlags($flags = null)

This method seems to be duplicated in your project.

    {
        if (null === $flags) {
            return self::NOPARAM;
        }

        $converted = 0;

        foreach (self::$flagMap as $from => $to) {
            if ($flags & $to) {
                $converted |= $from;
            }
        }

        return $converted;
    }
}