use kwargs in publish and message

Author: vadim.kar

CHANGELOG.md

@@ -1,7 +1,7 @@
 # Changelog
 All notable changes to this project will be documented in this file.
 
-## [1.6.4] - 2025-08-19
+## [1.7.0] - 2025-08-19
 ### Added
 - Ability to specify a custom job class for publishing via `publishing_job_class_callable` config.
 - Ability to specify a default queue for publishing jobs via `default_publishing_job_queue` config.

Gemfile.lock

@@ -8,7 +8,7 @@ GIT
 PATH
   remote: .
   specs:
-    rabbit_messaging (1.6.4)
+    rabbit_messaging (1.7.0)
       bunny (~> 2.0)
       kicks
 

lib/rabbit.rb

@@ -169,11 +169,27 @@ def configure
     config.validate!
   end
 
-  def publish(message_options, custom_queue_name: nil)
-    # Extract custom_queue_name from message_options for backward compatibility
-    custom_queue_name ||= message_options[:custom_queue_name]
-
-    message = Publishing::Message.new(message_options)
+  def publish(
+    routing_key: nil,
+    event: nil,
+    data: {},
+    exchange_name: [],
+    confirm_select: true,
+    realtime: false,
+    headers: {},
+    message_id: nil,
+    custom_queue_name: nil
+  )
+    message = Publishing::Message.new(
+      routing_key: routing_key,
+      event: event,
+      data: data,
+      exchange_name: exchange_name,
+      confirm_select: confirm_select,
+      realtime: realtime,
+      headers: headers,
+      message_id: message_id,
+    )
     publish_job_callable = config.publishing_job_class_callable || Publishing::Job
     queue_name = custom_queue_name || default_queue_name
 

lib/rabbit/publishing/job.rb

@@ -5,7 +5,7 @@
 module Rabbit::Publishing
   class Job < ActiveJob::Base
     def perform(message)
-      Rabbit::Publishing.publish(Message.new(message))
+      Rabbit::Publishing.publish(Message.new(**message))
     end
   end
 end

lib/rabbit/publishing/message.rb

@@ -9,15 +9,24 @@ class Message
     alias_method :confirm_select?, :confirm_select
     alias_method :realtime?, :realtime
 
-    def initialize(attributes = {})
-      self.routing_key     = attributes[:routing_key]
-      self.event           = attributes[:event]&.to_s
-      self.data            = attributes.fetch(:data, {})
-      self.exchange_name   = Array(attributes.fetch(:exchange_name, []))
-      self.confirm_select  = attributes.fetch(:confirm_select, true)
-      self.realtime        = attributes.fetch(:realtime, false)
-      self.headers         = attributes.fetch(:headers, {})
-      self.message_id      = attributes[:message_id]
+    def initialize(
+      routing_key: nil,
+      event: nil,
+      data: {},
+      exchange_name: [],
+      confirm_select: true,
+      realtime: false,
+      headers: {},
+      message_id: nil
+    )
+      self.routing_key = routing_key
+      self.event = event&.to_s
+      self.data = data
+      self.exchange_name = Array(exchange_name)
+      self.confirm_select = confirm_select
+      self.realtime = realtime
+      self.headers = headers
+      self.message_id = message_id
     end
 
     def to_hash

lib/rabbit/version.rb

@@ -1,5 +1,5 @@
 # frozen_string_literal: true
 
 module Rabbit
-  VERSION = "1.6.4"
+  VERSION = "1.7.0"
 end

spec/units/rabbit/publishing/message_spec.rb

@@ -2,7 +2,7 @@
 
 describe Rabbit::Publishing::Message do
   describe "basic_publish_args" do
-    subject(:message) { described_class.new(attributes) }
+    subject(:message) { described_class.new(**attributes) }
 
     context "rounting key not specified" do
       let(:attributes) { Hash[event: :ping] }

spec/units/rabbit_spec.rb

@@ -80,7 +80,7 @@
         test_group_id.test_project_id.some_exchange / some_queue / {"foo":"bar"} / some_event / \
         confirm: ...world"}
       MSG
-      described_class.publish(message_options, **additional_params)
+      described_class.publish(**message_options, **additional_params)
     end
 
     after do
@@ -134,13 +134,13 @@
         confirm: {"hello":"world"}
       MSG
 
-      expect { described_class.publish(message_options) }.not_to raise_error
+      expect { described_class.publish(**message_options) }.not_to raise_error
     end
 
     it "raises the last exception after max retries" do
       allow(channel).to receive(:basic_publish).and_raise(Bunny::ConnectionClosedError.new(""))
 
-      expect { described_class.publish(message_options) }
+      expect { described_class.publish(**message_options) }
         .to raise_error(Bunny::ConnectionClosedError)
     end
   end