[TOC] ### 消息應答 ack >[danger] noAck: false 手動接收消息模式 ``` async consume() { const ch = await this.app.amqplib.createChannel(); await ch.assertQueue(queueName, { durable: false }); const msg = await new Promise(resolve => ch.consume(queueName, msg => resolve(msg) , { noAck: false } )); if (msg !== null) { // 告訴MQ 我已經收到消息并處理完成了，MQ會刪除隊列中的消息，并從內存中刪除 ch.ack(msg); await ch.close(); this.ctx.status = 200; this.ctx.body = { msg: msg.content.toString() }; } else { this.ctx.status = 500; } } ``` ***** ### 消息持久化