我想在兔子中发送和保存一些数据;过了一会儿,我运行我的代码,向我的兔子发送了一些数据后,我得到了一些像这样的错误:错误:没有通道可以分配
我多次使用此代码,因为我有几个数据要发送到rabbitMQ
let open = require('amqplib').connect('amqp://localhost:5672')
open.then(function (conn) {
return conn.createChannel()
}).then(function (ch) {
return ch.assertQueue(q).then(function (ok) {
ch.sendToQueue(q, Buffer.from(JSON.stringify(data)))
return ch.close()
})
}).catch(console.warn)