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

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