Я экспортирую функцию pub
для rabbitmq
const pub = (queueName, data) => {
// console.log(data)
console.log(` [amqp][sending] - ${queueName}`)
// ch.assertQueue(queueName);
ch.sendToQueue(queueName, Buffer.from(data));
}
module.exports = {
pub,
connect
}
при импорте, я использую
const { pub } = require('../amqp')
, при использовании я делаю
try {
pub(channel, JSON.stringify(data))
} catch (error) {
console.log(error)
console.log(` [AMQP][error] cant send to queue`)
}
Вроде все хорошо, но я получаю сообщение об ошибке
TypeError: pub is not a function
Когда я наведу курсор на pub
, я вижу, что это функция. ссылка
Я застрял с этим в течение нескольких часов и понятия не имею, как действовать дальше.