小编Luc*_*asC的帖子

我想知道如何推迟使用Amqpphplib.

我用过这个很棒的咖啡脚本教程:

https://github.com/jamescarr/rabbitmq-scheduled-delivery

但它似乎不适用于PHP-amqplib.

消息按我的意愿到期,但似乎"x-dead-letter-exchange"不能完成这项工作.我使用了RabbitMQ管理控制台,我看到了所有队列的创建和删除.但是我的消息在到期后会立即进入队列.我使用RabbitMQ 3.2.3版本,PHP-amqplib 2.2.*版本.

这是我的代码:

连接类:

class Connection
{
/**
 * @var $ch
 */
public $ch;

/**
 * @var $consumer_tag
 */
public $consumer_tag;

/**
 * @var $exchange
 */
public $exchange;

/**
 * @var $conn
 */
public $conn;

public function __construct($host, $port, $user, $password, $vhost)
{

    $this->exchange = 'immediate';
    $this->queue = 'right.now.queue';
    $this->consumer_tag = 'consumer';


    $this->conn = new AMQPConnection($host, $port, $user, $password, $vhost);
    $this->ch = $this->conn->channel();

    $this->ch->exchange_declare($this->exchange, 'direct', false, true, false);

    $this->ch->queue_declare($this->queue, false, true, false, false, false);

    $this->ch->queue_bind($this->queue, …