Pass header to Minion job

jgwmaxwell · Aug 21, 2011 · 6c883a0 · 6c883a0
1 parent 0323938
commit 6c883a0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/minion/handler.rb b/lib/minion/handler.rb
@@ -68,8 +68,8 @@ def subscribe
         AMQP::Channel.new.queue(queue, durable: true, auto_delete: false).subscribe(ack: true) do |h, m|
           return if AMQP.closing?
           begin
-            Minion.info("Received: #{queue}:#{m}")
-            block.call(decode(m))
+            Minion.info("Received: #{queue}:#{m}, #{h}")
+            block.call(decode(m), h)
           rescue Object => e
             Minion.alert(e)
           end