From: Christos KK Loverdos <loverdos@gmail.com>
Date: Fri, 25 May 2012 09:32:55 +0000 (+0300)
Subject: Set rabbitmq heartbeat
X-Git-Url: https://code.grnet.gr/git/aquarium/commitdiff_plain/671a88185600daef36bfc93e86d46fb95b038554

Set rabbitmq heartbeat
---

diff --git a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
index d630b44..2b10bf1 100644
--- a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
+++ b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
@@ -171,6 +171,7 @@ class RabbitMQConsumer(val conf: RabbitMQConsumerConf,
       factory.setUsername(connectionConf(RabbitMQConKeys.username))
       factory.setPassword(connectionConf(RabbitMQConKeys.password))
       factory.setVirtualHost(connectionConf(RabbitMQConKeys.vhost))
+      factory.setRequestedHeartbeat(connectionConf(RabbitMQConKeys.reconnect_period_millis).toInt)
 
       val connection = factory.newConnection(servers)