From e43ab395e69185bb2b73a1db43229ea21c11b2c5 Mon Sep 17 00:00:00 2001 From: Nimer Farahty Date: Sun, 20 Apr 2025 21:55:29 +0300 Subject: [PATCH] change prefetch settings --- index.ts | 1 + 1 file changed, 1 insertion(+) diff --git a/index.ts b/index.ts index 00261c1..e68ce2f 100644 --- a/index.ts +++ b/index.ts @@ -11,6 +11,7 @@ const rabbitUrl = process.env.RABBITMQ_URL || "amqp://localhost"; async function start() { const conn = await amqp.connect(rabbitUrl); const channel = await conn.createChannel(); + await channel.prefetch(1); await channel.assertQueue(queueName); console.log(`🎧 Listening for messages on "${queueName}"...`);