lib/splash/transports/rabbitmq.rb in prometheus-splash-0.6.0 vs lib/splash/transports/rabbitmq.rb in prometheus-splash-0.6.1

@@ -98,10 +98,9 @@
           lock = Mutex.new
           res = nil
           condition = ConditionVariable.new
           get_default_subscriber(queue: queue).subscribe do |delivery_info, properties, payload|
             res = YAML::load(payload)
-
             lock.synchronize { condition.signal }
           end
           get_logger.send "Verb : #{order[:verb].to_s} to queue : #{order[:queue]}."
           get_default_client.publish queue: order[:queue], message: order.to_yaml
           lock.synchronize { condition.wait(lock) }