如何在nodejs函数postwait amqp中传递参数
How to pass argument in nodejs function postwait amqp
我是 nodejs 新手。我正在使用 this function
connection.queue(name[, options][, openCallback])
在 nodejs 中,但我无法弄清楚如何在函数调用中传递选项(被动、持久等)
这是我的代码片段:
console.log("rabbit mq connnection ready");
connection.queue('myNotifications_' + userId , {autoDelete:false , durable:true } ,function(q){
q.bind('#');
console.log('subsscribe to queue');
上面我使用 json 来传递参数 { autodelete:false , durable:true} 但它似乎不起作用。
任何帮助
我从 postwait-amqp 转移到 amqplib nodejs 。 postwait-amqp 似乎有一些错误。
我是 nodejs 新手。我正在使用 this function
connection.queue(name[, options][, openCallback])
在 nodejs 中,但我无法弄清楚如何在函数调用中传递选项(被动、持久等)
这是我的代码片段:
console.log("rabbit mq connnection ready");
connection.queue('myNotifications_' + userId , {autoDelete:false , durable:true } ,function(q){
q.bind('#');
console.log('subsscribe to queue');
上面我使用 json 来传递参数 { autodelete:false , durable:true} 但它似乎不起作用。
任何帮助
我从 postwait-amqp 转移到 amqplib nodejs 。 postwait-amqp 似乎有一些错误。