lib/waffle/transports/rabbitmq.rb in waffle-0.3.1 vs lib/waffle/transports/rabbitmq.rb in waffle-0.3.2

@@ -28,10 +28,10 @@
         else
           @queue.bind @exchange, :key => flow
         end
 
         @queue.subscribe do |message|
-          yield encoder.decode(message[:payload])
+          yield message[:routing_key], encoder.decode(message[:payload])
         end
       end
 
     end
   end