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