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