Change prefetch count

freenowtech · Sep 28, 2021 · 6644a30 · 6644a30
1 parent 99c3c41
commit 6644a30
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/sauron-service/src/main/java/com/freenow/sauron/config/RabbitmqConfig.java b/sauron-service/src/main/java/com/freenow/sauron/config/RabbitmqConfig.java
@@ -1,6 +1,8 @@
 package com.freenow.sauron.config;
 
 import org.springframework.amqp.core.Queue;
+import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
+import org.springframework.beans.factory.annotation.Qualifier;
 import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -16,4 +18,12 @@ public Queue sauronQueue()
     {
         return new Queue(SAURON_QUEUE_NAME, true);
     }
+
+
+    @Bean
+    public SimpleRabbitListenerContainerFactory eventBusPrefetchCount(@Qualifier("eventBus") SimpleRabbitListenerContainerFactory eventBus)
+    {
+        eventBus.setPrefetchCount(1);
+        return eventBus;
+    }
 }