We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8c7ad3d commit fcc99feCopy full SHA for fcc99fe
src/consumer/rabbitmq-messaging.consumer.ts
@@ -27,10 +27,12 @@ export class RabbitmqMessagingConsumer
27
await this.rabbitMqMigrator.run(channel);
28
29
const amqpChannel = channel.channel;
30
+
31
if (!amqpChannel) {
32
throw new Error('AMQP channel not initialized');
33
}
34
35
+ await amqpChannel.prefetch(1);
36
await amqpChannel.consume(
37
channel.config.queue,
38
async (msg) => {
0 commit comments