Innmind\AMQP\Model\Basic\Consume

Complexity

Total Complexity

21

Size/Duplication

Total Lines	155
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

20 Methods

Rating	Name	Duplication	Size	Complexity
A	shouldAutoAcknowledge()	0	3	1
A	arguments()	0	3	1
A	isExclusive()	0	3	1
A	consumerTag()	0	3	1
A	shouldAutoGenerateConsumerTag()	0	3	1
A	isLocal()	0	3	1
A	queue()	0	3	1
A	shouldWait()	0	3	1
A	__construct()	0	4	1
A	withArgument()	0	6	1
A	wait()	0	6	1
A	dontWait()	0	10	2
A	noLocal()	0	6	1
A	manualAcknowledge()	0	6	1
A	withConsumerTag()	0	6	1
A	autoAcknowledge()	0	6	1
A	exclusive()	0	6	1
A	local()	0	6	1
A	notExclusive()	0	6	1
A	withAutoGeneratedConsumerTag()	0	6	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Model\Basic;

use Innmind\AMQP\Exception\AutoGeneratedConsumerTagRequireServerResponse;
use Innmind\Immutable\{
    MapInterface,
    Map,
};

final class Consume
{
    private $queue;
    private $consumerTag;
    private $local = true;
    private $ack = true;
    private $exclusive = false;
    private $wait = true;
    private $arguments;

    public function __construct(string $queue)
    {
        $this->queue = $queue;
        $this->arguments = new Map('string', 'mixed');
    }

    public function withConsumerTag(string $tag): self
    {
        $self = clone $this;
        $self->consumerTag = $tag;

        return $self;
    }

    /**
     * Let the server define the consumer tag
     */
    public function withAutoGeneratedConsumerTag(): self
    {
        $self = clone $this;
        $self->consumerTag = null;

        return $self;
    }

    /**
     * Means the server will not deliver messages to the consumer
     */
    public function noLocal(): self
    {
        $self = clone $this;
        $self->local = false;

        return $self;
    }

    public function local(): self
    {
        $self = clone $this;
        $self->local = true;

        return $self;
    }

    public function manualAcknowledge(): self
    {
        $self = clone $this;
        $self->ack = true;

        return $self;
    }

    public function autoAcknowledge(): self
    {
        $self = clone $this;
        $self->ack = false;

        return $self;
    }

    public function exclusive(): self
    {
        $self = clone $this;
        $self->exclusive = true;

        return $self;
    }

    public function notExclusive(): self
    {
        $self = clone $this;
        $self->exclusive = false;

        return $self;
    }

    public function dontWait(): self
    {
        if ($this->shouldAutoGenerateConsumerTag()) {
            throw new AutoGeneratedConsumerTagRequireServerResponse;
        }

        $self = clone $this;
        $self->wait = false;

        return $self;
    }

    public function wait(): self
    {
        $self = clone $this;
        $self->wait = true;

        return $self;
    }

    public function withArgument(string $key, $value): self
    {
        $self = clone $this;
        $self->arguments = $self->arguments->put($key, $value);

        return $self;
    }

    public function queue(): string
    {
        return $this->queue;
    }

    public function shouldAutoGenerateConsumerTag(): bool
    {
        return !\is_string($this->consumerTag);
    }

    public function consumerTag(): string
    {
        return $this->consumerTag;
    }

    public function isLocal(): bool
    {
        return $this->local;
    }

    public function shouldAutoAcknowledge(): bool
    {
        return !$this->ack;
    }

    public function isExclusive(): bool
    {
        return $this->exclusive;
    }

    public function shouldWait(): bool
    {
        return $this->wait;
    }

    /**
     * @return MapInterface<string, mixed>
     */
    public function arguments(): MapInterface
    {
        return $this->arguments;
    }
}