Final Class Yiisoft\Queue\Amqp\QueueProvider

                public function __clone()
{
    $this->channelId = null;
}

            

                public function __construct(
    private readonly AbstractConnection $connection,
    private QueueSettingsInterface $queueSettings,
    private ?ExchangeSettingsInterface $exchangeSettings = null,
    private array $messageProperties = [],
) {}

            

                public function __destruct()
{
    if ($this->channelId !== null) {
        $this->connection->channel($this->channelId)->close();
    }
}

            

                public function channelClose(): void
{
    if ($this->channelId !== null) {
        $this->connection->channel($this->channelId)->close();
        $this->channelId = null;
    }
}

            

                public function getChannel(): AMQPChannel
{
    if ($this->channelId !== null) {
        return $this->connection->channel($this->channelId);
    }
    $this->channelId = $this->connection->get_free_channel_id();
    $channel = $this->connection->channel($this->channelId);
    $channel->queue_declare(...$this->queueSettings->getPositionalSettings());
    if ($this->exchangeSettings !== null) {
        $channel->exchange_declare(...$this->exchangeSettings->getPositionalSettings());
        $channel->queue_bind($this->queueSettings->getName(), $this->exchangeSettings->getName());
    }
    return $channel;
}

            

                public function getExchangeSettings(): ?ExchangeSettingsInterface
{
    return $this->exchangeSettings;
}

            

                public function getMessageProperties(): array
{
    return $this->messageProperties;
}

            

                public function getQueueSettings(): QueueSettingsInterface
{
    return $this->queueSettings;
}

            

                public function withExchangeSettings(?ExchangeSettingsInterface $exchangeSettings): QueueProviderInterface
{
    $new = clone $this;
    $new->exchangeSettings = $exchangeSettings;
    return $new;
}

            

                public function withMessageProperties(array $properties): QueueProviderInterface
{
    $new = clone $this;
    $new->messageProperties = $properties;
    return $new;
}

            

                public function withQueueName(string $queue): self
{
    if ($queue === $this->queueSettings->getName()) {
        return $this;
    }
    if ($this->exchangeSettings !== null) {
        throw new ExchangeDeclaredException();
    }
    $instance = clone $this;
    $instance->queueSettings = $instance->queueSettings->withName($queue);
    return $instance;
}

            

                public function withQueueSettings(QueueSettingsInterface $queueSettings): QueueProviderInterface
{
    $new = clone $this;
    $new->queueSettings = $queueSettings;
    return $new;
}