lib/recognizer/amqp.rb in recognizer-0.1.2 vs lib/recognizer/amqp.rb in recognizer-0.1.3

@@ -19,19 +19,20 @@
 
         amqp = Bunny.new(options[:amqp].reject { |key, value| key == :exchange })
         amqp.start
 
         exchange = amqp.exchange(exchange_name, :type => exchange_type.to_sym, :durable => durable)
-        queue = amqp.queue("recognizer")
+        queue    = amqp.queue("recognizer")
         queue.bind(exchange, :key => routing_key)
 
         Thread.abort_on_exception = true
 
         Thread.new do
           logger.info("AMQP -- Awaiting metrics with impatience ...")
           queue.subscribe do |message|
             payload         = message[:payload]
             msg_routing_key = message[:routing_key] || message[:delivery_details][:routing_key]
+
             lines = payload.split("\n")
             lines.each do |line|
               line = line.strip
               case line.split("\s").count
               when 3