队列中有 10 条消息。 有没有办法在 10 条消息中只消费 5 条消息? 我正在使用 nodejs。
这是我的源代码:
consumer.js
const consumer = async ({routeKey}) => {
const fastify = Fastify({
logger: true
})
await fastify.register(fastifyAmqp, {
protocol: 'amqp',
hostname: 'localhost',
port: 5672,
username: 'admin',
password: 'admin',
})
const channel = await fastify.amqp.channel;
const queue = 'users'
channel.assertQueue(queue, {
durable: true,
})
await channel.consume(q.queue, function (msg) {
if (msg.content) {
JSON.parse(msg.content.toString())
}
}, {
noAck: false
});}