From: Georgios Gousios <gousiosg@gmail.com>
Date: Thu, 22 Mar 2012 09:36:49 +0000 (+0200)
Subject: Set queue prefetch size to 1.
X-Git-Url: https://code.grnet.gr/git/aquarium/commitdiff_plain/8a563752faa4ea584b9b285ae2912462762d1213

Set queue prefetch size to 1.

This might decrease queue reading performance but it also
increases the chances of no messages get lost if Aquarium
crashes
---

diff --git a/src/main/scala/gr/grnet/aquarium/messaging/AkkaAMQP.scala b/src/main/scala/gr/grnet/aquarium/messaging/AkkaAMQP.scala
index 346323f..33546a1 100644
--- a/src/main/scala/gr/grnet/aquarium/messaging/AkkaAMQP.scala
+++ b/src/main/scala/gr/grnet/aquarium/messaging/AkkaAMQP.scala
@@ -94,7 +94,9 @@ trait AkkaAMQP extends Loggable {
         deliveryHandler = recipient,
         queueName = Some(queue),
         queueDeclaration = decl,
-        selfAcknowledging = selfAck
+        selfAcknowledging = selfAck,
+        /* Better safe than sorry */
+        channelParameters = Some(ChannelParameters(prefetchSize = 1))
         ))
 
   def producer(exchange: String) = {
@@ -103,6 +105,6 @@ trait AkkaAMQP extends Loggable {
       connection = (new AMQPConnection()).connection,
       producerParameters = ProducerParameters(
         exchangeParameters = Some(ExchangeParameters(exchange, Topic, decl)),
-        channelParameters = Some(ChannelParameters(prefetchSize = 0))))
+        channelParameters = Some(ChannelParameters(prefetchSize = 1))))
   }
 }
\ No newline at end of file