ditkrg/rabbit_carrots
5
0
Fork 0
mirror of https://github.com/ditkrg/rabbit_carrots.git synced 2026-01-25 07:06:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: Add exchange_name parameter to run_task method and update Rubocop configuration for parameter lists.

Browse Source
This commit is contained in:
Ari Karim
2026-01-18 11:04:42 +03:00
parent 4ac772d12c
commit d7c7415438
2 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
lib/rabbit_carrots/core.rb
View File

@@ -36,6 +36,7 @@ module RabbitCarrots
handler_class:,
routing_keys: channel[:routing_keys],
queue_arguments: channel[:arguments],
exchange_name: channel[:exchange_name],
kill_to_restart_on_standard_error:
)
end
@@ -76,9 +77,9 @@ module RabbitCarrots
@running = false
end
def run_task(queue_name:, handler_class:, routing_keys:, queue_arguments: {}, kill_to_restart_on_standard_error: false)
def run_task(queue_name:, handler_class:, routing_keys:, queue_arguments: {}, exchange_name: nil, kill_to_restart_on_standard_error: false)
RabbitCarrots::Connection.instance.channel.with do |channel|
exchange = channel.topic(RabbitCarrots.configuration.rabbitmq_exchange_name, durable: true)
exchange = channel.topic(exchange_name || RabbitCarrots.configuration.rabbitmq_exchange_name, durable: true)
logger.info "Listening on QUEUE: #{queue_name} for ROUTING KEYS: #{routing_keys}"
queue = channel.queue(queue_name, durable: true, arguments: queue_arguments)