"""
    @desc Создание очереди с задержкой и обменника
    @param string $exchange_name
    @param string $queue_name
    @param string $ttl_time
"""
public function createOutQueue($exchange_name = '', $queue_name = '', $ttl_time = '')
{
    $this->delay_exchange_name = $exchange_name;
    $this->delay_queue_name = $queue_name;
    self::$ttl_time = $ttl_time ?  $ttl_time : 15000;
    try {
        $this->setExchangeDeclare($this->delay_exchange_name, self::$type, false, false, false);
        $this->getQueueDeclare($this->delay_queue_name, false, true, false, false, false);
        $this->setQueueBind($this->delay_queue_name, $this->delay_exchange_name, $this->delay_exchange_name);
    } catch (\Exception $e) {
        return 'Info:' .  $e->getMessage();
    }
}

/**
     * @desc Создание очереди и обменника
     * @param string $exchange_name
     * @param string $queue_name
     * @return string
     */
public function createDefaultQueue($exchange_name = '', $queue_name = '')
{
    $this->exchange_name = $exchange_name;
    $this->queue_name = $queue_name;
    try {
        $tale = new AMQPTable();
``````markdown
```php
$tale->set('x-dead-letter-exchange', $this->delay_exchange_name); // Указывает, какой обменник будет обрабатывать сообщение после истечения срока его жизни
$tale->set('x-dead-letter-routing-key', $this->delay_exchange_name); // Ключ маршрутизации для сообщений-мертвых пачек
$tale->set('x-message-ttl', self::$ttl_time); // Время жизни сообщения
$this->setExchangeDeclare($this->exchange_name, self::$type, false, false, false);
$this->getQueueDeclare($this->queue_name, false, true, false, false, false, $tale);
$this->setQueueBind($this->queue_name, $this->exchange_name, $this->exchange_name);
} catch (\Exception $e) {
return 'Info:' . $e->getMessage();
}
}

/**
 * @desc Отправка сообщения
 * @param string $message
 */
public function sendMessage($message = '')
{
    // Для тестирования отправляем несколько сообщений
    for ($i = 1; $i <= 10; $i++) {
        $messages = new AMQPMessage($message, [
            'expiration' => intval(self::$ttl_time),
            'delivery_mode' => AMQPMessage::DELIVERY_MODE_PERSISTENT
        ]);
        $this->amqp_channel->basic_publish($messages, $this->exchange_name, $this->exchange_name);
        // Для удобства просмотра отправленных сообщений
        sleep(2);
        echo date('Y-m-d H:i:s') . ' Sent ' . $message . PHP_EOL;
    }
}

```php
/**
    * @desc Прием сообщения и его обработка
    */
public function receiveMessage()
{
    echo 'Ожидание сообщения. Для выхода нажмите CTRL+C ' . PHP_EOL;

    $callback = function ($message) {

        echo date('Y-m-d H:i:s') . " Received: ", $message->body, PHP_EOL;

        $message->delivery_info['channel']->basic_ack($message->delivery_info['delivery_tag']); 
    };
    $this->amqp_channel->basic_qos(null, 1, null);

    $this->amqp_channel->basic_consume($this->delay_queue_name, '', false, false, false, false, $callback);
}
```markdown
    while (count($this->amqp_channel->callbacks)) {

        $this->amqp_channel->wait();
    }
}