lib/rabbit/receiving/worker.rb in rabbit_messaging-0.8.1 vs lib/rabbit/receiving/worker.rb in rabbit_messaging-0.9.0
- old
+ new
@@ -7,10 +7,11 @@
class Rabbit::Receiving::Worker
include Sneakers::Worker
def work_with_params(message, delivery_info, arguments)
- receive_message(message, delivery_info, arguments)
+ # args and info have custom rabbit classes, have to convert them to hash
+ receive_message(message, delivery_info.to_h, arguments.to_h)
ack!
rescue => error
handle_error!(error)
end