amqp_delay_via_plugin.php

<?php
/** 
 * @var \Enqueue\AmqpExt\AmqpMessage $message
 * @var \Enqueue\AmqpExt\AmqpContext $context
 * @var \Enqueue\AmqpExt\AmqpConsumer $consumer 
 */

if ($message->isRedelivered()) {
    $queue = $context->createQueue('a_queue');
  
    $delayTopic = $context->createTopic('a_retry_exchange');
    $delayTopic->setRoutingKey('a_queue');
    $delayTopic->setType('x-delayed-message');
    $delayTopic->addFlag(AMQP_DURABLE);
    $delayTopic->setArguments([
        'x-delayed-type' => 'direct',
    ]);  
    
    $context->declareTopic($delayTopic);
    $context->bind($delayTopic, $queue);
    
    $retryMessage = $context->createMessage(
        $message->getBody(),
        $message->getProperties(), 
        $message->getHeaders()
    );
    $retryMessage->setProperty('x-delay', '5000'));

    $context->createProducer()->send($delayTopic, $retryMessage);
    
    $consumer->acknowledge($message);   
}