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 (file)
--- 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