Remove shutdown listener when stopping the rabbitmq consumer

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 2b10bf1..ad3ef4f 100644 (file)
--- a/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
+++ b/src/main/scala/gr/grnet/aquarium/connector/rabbitmq/RabbitMQConsumer.scala
@@ -251,6 +251,7 @@ class RabbitMQConsumer(val conf: RabbitMQConsumerConf,
 
   def safeStop() = {
     _state.set(ShutdownSequence)
+    safeUnit(_channel.removeShutdownListener(RabbitMQShutdownListener))
     safeUnit(_channel.close())
     safeUnit(_connection.close())
     _state.set(Shutdown)