ButterAMQP\AMQP091\Consumer

Complexity

Total Complexity

5

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

100%

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	cancel()	0	6	1
A	tag()	0	4	1
A	isActive()	0	4	1
A	__toString()	0	4	1

<?php

namespace ButterAMQP\AMQP091;

use ButterAMQP\ChannelInterface;
use ButterAMQP\ConsumerInterface;

class Consumer implements ConsumerInterface
{
    const FLAG_NO_WAIT = 0b0000000001;
    const FLAG_EXCLUSIVE = 0b0000001000;
    const FLAG_NO_LOCAL = 0b0100000000;
    const FLAG_NO_ACK = 0b1000000000;

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

    /**
     * @var string
     */
    private $tag;

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

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

        return $this;
    }

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

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

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