@@ -97,6 +97,14 @@ require "rabbit_messaging"
9797 }
9898 ` ` `
9999
100+ - ` publishing_job_class_callable` (` Proc` )
101+
102+ Custom job class (e.g. ActiveJob or Sidekiq ::Job ) to work with published messages.
103+
104+ - ` default_publishing_job_queue` (` String` or ` Symbol` )
105+
106+ The name of the queue that will be used by default for publishing jobs. ` default` by default.
107+
100108 - ` before_receiving_hooks, after_receiving_hooks` (` Array of Procs` )
101109
102110 Before and after hooks with message processing in the middle. Where ` before_receiving_hooks` and ` after_receiving_hooks` are empty arrays by default.
@@ -139,7 +147,7 @@ require "rabbit_messaging"
139147 - `connection_reset_max_retries` (`Integer`)
140148
141149 Maximum number of reconnection attempts after a connection loss. Default: 10.
142-
150+
143151 ```ruby
144152 config.connection_reset_max_retries = 20
145153 ```
@@ -165,13 +173,16 @@ require "rabbit_messaging"
165173
166174```ruby
167175Rabbit.publish(
168- routing_key: :support,
169- event: :ping,
170- data: { foo: :bar }, # default is {}
171- exchange_name: ' fanout' , # default is fine too
172- confirm_select: true, # setting this to false grants you great speed up and absolutelly no guarantees
173- headers: { "foo" => "bar" }, # custom arguments for routing, default is {}
174- message_id: "asdadsadsad", # A unique identifier such as a UUID that your application can use to identify the message.
176+ {
177+ routing_key: :support,
178+ event: :ping,
179+ data: { foo: :bar }, # default is {}
180+ exchange_name: ' fanout' , # default is fine too
181+ confirm_select: true, # setting this to false grants you great speed up and absolutelly no guarantees
182+ headers: { "foo" => "bar" }, # custom arguments for routing, default is {}
183+ message_id: "asdadsadsad", # A unique identifier such as a UUID that your application can use to identify the message.
184+ },
185+ custom_queue_name: :my_custom_queue, # The name of the queue for publishing jobs. Overrides the default queue.
175186)
176187```
177188
0 commit comments