Innmind\AMQP\Model\Queue\Declaration

Complexity

Total Complexity

23

Size/Duplication

Total Lines	183
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

20 Methods

Rating	Name	Duplication	Size	Complexity
A	isDurable()	0	3	1
A	isExclusive()	0	3	1
A	shouldWait()	0	3	1
A	name()	0	3	1
A	__construct()	0	3	1
A	temporary()	0	3	1
A	shouldAutoGenerateName()	0	3	1
A	isAutoDeleted()	0	3	1
A	arguments()	0	3	1
A	isPassive()	0	3	1
A	autoDelete()	0	6	1
A	withArgument()	0	6	1
A	notExclusive()	0	6	1
A	dontWait()	0	10	2
A	withAutoGeneratedName()	0	10	2
A	durable()	0	6	1
A	exclusive()	0	10	2
A	passive()	0	6	1
A	withName()	0	6	1
A	wait()	0	6	1

<?php
declare(strict_types = 1);

namespace Innmind\AMQP\Model\Queue;

use Innmind\AMQP\Exception\{
    ExclusivePassiveDeclarationNotAllowed,
    NotWaitingPassiveDeclarationDoesNothing,
    PassiveQueueDeclarationMustHaveAName,
};
use Innmind\Immutable\{
    MapInterface,
    Map,
};

final class Declaration
{
    private $name;
    private $passive = false;
    private $durable = false;
    private $autoDelete = false;
    private $exclusive = false;
    private $wait = true;
    private $arguments;

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

    /**
     * Check if the queue exists on the server
     */
    public static function passive(string $name): self
    {
        $self = new self;
        $self->passive = true;

        return $self->withName($name);
    }

    /**
     * The queue will survive after a server restart
     */
    public static function durable(): self
    {
        $self = new self;
        $self->durable = true;

        return $self;
    }

    /**
     * The queue will disappear after a server restart
     */
    public static function temporary(): self
    {
        return new self;
    }

    /**
     * The queue is deleted once all consumers have finished using it
     */
    public static function autoDelete(): self
    {
        $self = new self;
        $self->autoDelete = true;

        return $self;
    }

    /**
     * Make the queue only accessible to the current connection
     */
    public function exclusive(): self
    {
        if ($this->isPassive()) {
            throw new ExclusivePassiveDeclarationNotAllowed;
        }

        $self = clone $this;
        $self->exclusive = true;

        return $self;
    }

    /**
     * Make the queue usable to all connections
     */
    public function notExclusive(): self
    {
        $self = clone $this;
        $self->exclusive = false;

        return $self;
    }

    /**
     * Don't wait for the server response
     */
    public function dontWait(): self
    {
        if ($this->isPassive()) {
            throw new NotWaitingPassiveDeclarationDoesNothing;
        }

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

        return $self;
    }

    /**
     * Wait for the server response
     */
    public function wait(): self
    {
        $self = clone $this;
        $self->wait = true;

        return $self;
    }

    /**
     * Name the queue with the given string
     */
    public function withName(string $name): self
    {
        $self = clone $this;
        $self->name = $name;

        return $self;
    }

    /**
     * Let the server generate a name for the queue
     */
    public function withAutoGeneratedName(): self
    {
        if ($this->isPassive()) {
            throw new PassiveQueueDeclarationMustHaveAName;
        }

        $self = clone $this;
        $self->name = null;

        return $self;
    }

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

        return $self;
    }

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

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

    public function isPassive(): bool
    {
        return $this->passive;
    }

    public function isDurable(): bool
    {
        return $this->durable;
    }

    public function isAutoDeleted(): bool
    {
        return $this->autoDelete;
    }

    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;
    }
}