Skip to content

Commit 2b4fc36

Browse files
committed
prefetch only 1 message
1 parent 67c6563 commit 2b4fc36

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

src/taskmaster.ts

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -36,6 +36,9 @@ amqp.connect(`amqp://${config.AMQP.USER}:${config.AMQP.PASS}@${config.AMQP.HOST}
3636
channel.assertQueue(successQ);
3737
channel.assertQueue(jobQ);
3838
channel.assertQueue(errorQ);
39+
40+
channel.prefetch(1);
41+
3942
channel.consume(jobQ, async (msg) => {
4043
try {
4144
const payload = JSON.parse(msg.content.toString())

0 commit comments

Comments
 (0)