lib/rabbit/receiving/receive.rb in rabbit_messaging-0.10.0 vs lib/rabbit/receiving/receive.rb in rabbit_messaging-0.11.0

- old
+ new

@@ -55,8 +55,12 @@ def queue Rabbit::Receiving::Queue.new(message, arguments).name end def job_class - Rabbit.config.receiving_job_class_callable&.call || Rabbit::Receiving::Job + Rabbit.config.receiving_job_class_callable&.call( + message: message, + delivery_info: delivery_info, + arguments: arguments, + ) || Rabbit::Receiving::Job end end