Merge pull request #7 from Happyr/Nyholm-patch-1

Adding prefetch=1
Happyr · Dec 30, 2017 · 2460d43 · 2460d43
2 parents bdbad64 + 5f2ada9
commit 2460d43
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);