f

vadim.kar · vadim.kar · commit 86cb92cc1afc · 2025-08-21T16:22:25.000+03:00
diff --git a/lib/rabbit.rb b/lib/rabbit.rb
@@ -190,7 +190,8 @@ def publish(
       headers: headers,
       message_id: message_id,
     )
-    publish_job_callable = config.publishing_job_class_callable || Publishing::Job
+    job_class = config.publishing_job_class_callable
+    publish_job_callable = job_class.is_a?(Proc) ? job_class.call : (job_class || Publishing::Job)
     queue_name = custom_queue_name || default_queue_name
 
     if message.realtime?

Original file line number	Diff line number	Diff line change
`@@ -190,7 +190,8 @@ def publish(`
`190`	`190`	`headers: headers,`
`191`	`191`	`message_id: message_id,`
`192`	`192`	`)`
`193`		`- publish_job_callable = config.publishing_job_class_callable \|\| Publishing::Job`
	`193`	`+ job_class = config.publishing_job_class_callable`
	`194`	`+ publish_job_callable = job_class.is_a?(Proc) ? job_class.call : (job_class \|\| Publishing::Job)`
`194`	`195`	`queue_name = custom_queue_name \|\| default_queue_name`
`195`	`196`
`196`	`197`	`if message.realtime?`