php

<?php

public function consume(ConsumerInterface $consumer, AbstractQueueName $queueName): void
{
    $consumerIdentified = (string)Uuid::uuid4();

    $this->channel->qos(0, 10, false);
    $this->channel->consume(
        fn(Message $message) => $this->handle($message, $consumer),
        $queueName,
        $consumerIdentified,
        false
    );

    while ($this->channel->isOpen()) {
        $this->channel->wait();
    }
}