их получения?
сейчас я всегда получаю одно и то же сообщение. хочу чтобы получил сообщение - обработал - получил следующее
вот мой коннект
const conn = await mq.connect(process.env.RABBIT_URL);
const ch = await conn.createChannel();
await ch.assertQueue(this.topic);
await ch.qos(1);
this.mq = ch;
вот я получаю сообщение
this.mq.consume(this.topic, async (msg) => {
console.log('callback msg: ', msg.content.toString());
});
Нужно acknowledge вызывать
Обсуждают сегодня