CODEWITHSUNDEEP
node.jsrabbitmqamqpttl
batazor
batazor

Reputation: 992

How to use x-message-ttl in node-amqp?

How to set x-message-ttl for queue RabbitMQ? I use node-amqp package.

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

Upvotes: 2

Views: 4403

Answers (2)

Nikhil
Nikhil

Reputation: 374

I am using the x-expires argument instead of x-message-ttl.

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

It is marking my Queue as Exp in the rabbit console but not deleting it after 20 seconds. I don't know what I am doing wrong

Upvotes: 1

pinepain
pinepain

Reputation: 12859

x-message-ttl is an argument. Arguments are passed under arguments options property, so something like

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

should do the job.

For more details see queue.js source code and queue.declare AMQP method documentation

Upvotes: 5

Related Questions