Skip to content

Commit 762db51

Browse files
author
vadim.kar
committed
fix custom_queue_name issue
1 parent 055e7fd commit 762db51

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

lib/rabbit.rb

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,10 @@ def configure
169169
config.validate!
170170
end
171171

172-
def publish(custom_queue_name: nil, **message_options)
172+
def publish(message_options, custom_queue_name: nil)
173+
# Extract custom_queue_name from message_options for backward compatibility
174+
custom_queue_name ||= message_options[:custom_queue_name]
175+
173176
message = Publishing::Message.new(message_options)
174177
publish_job_callable = config.publishing_job_class_callable || Publishing::Job
175178
queue_name = custom_queue_name || default_queue_name

0 commit comments

Comments
 (0)