如何在 node-amqp 中使用 x-message-ttl？

Question

如何为队列RabbitMQ设置x-message-ttl？我使用 node-amqp 包。

connection.queue('echo', {autoDelete: false, durable: true, "x-message-ttl":20000});

Answer 1

x-message-ttl是一个参数。参数在 arguments 选项 属性 下传递，所以类似于

connection.queue('echo', {
    autoDelete : false,
    durable    : true,
    arguments  : {
        "x-message-ttl" : 20000
    }
});

应该完成这项工作。

有关详细信息，请参阅 queue.js source code and queue.declare AMQP method documentation

Answer 2

我正在使用 x-expires 参数而不是 x-message-ttl。

connection.queue('echo',{
    autoDelete:false,
    durable:false,
    arguments:{
        "x-expires":20000
     }
});

它在 rabbit 控制台中将我的队列标记为 Exp，但 20 秒后未将其删除。 我不知道我做错了什么