Fix compilation error due to API change in rabbitmq client lib

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 ad3ef4f..8855b51 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
+++ b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
@@ -313,7 +313,8 @@ class RabbitMQConsumer(val conf: RabbitMQConsumerConf,
     def handleShutdownSignal(consumerTag: String, sig: ShutdownSignalException) = {
     }
 
-    def handleRecoverOk() = {
+
+    def handleRecoverOk(consumerTag: String) = {
     }
 
     def handleDelivery(consumerTag: String, envelope: Envelope, properties: BasicProperties, body: Array[Byte]) = {