Adding prefetch=1

Happyr · Dec 30, 2017 · 5f2ada9 · 5f2ada9
1 parent bdbad64
commit 5f2ada9
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/java/com/happyr/mq2php/queue/RabbitMqClient.java b/src/main/java/com/happyr/mq2php/queue/RabbitMqClient.java
@@ -37,6 +37,7 @@ public RabbitMqClient(String queueName, MessageConsumer mc) {
             channel = connection.createChannel();
 
             channel.queueDeclare(queueName, true, false, false, null);
+            channel.basicQos(1);
 
             consumer = new QueueingConsumer(channel);
             channel.basicConsume(queueName, false, consumer);