ditkrg/rabbit_carrots
4
0
Fork 0
mirror of https://github.com/ditkrg/rabbit_carrots.git synced 2026-01-22 22:06:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #14 from arikarim/multi-exchange-

Browse Source 
feat: Add exchange_name parameter to run_task method and update Ruboc…
This commit is contained in:
Brusk Awat 2026-01-18 12:04:10 +03:00 committed by GitHub
commit 5d2e2df8d2
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.rubocop.yml
View File

@ -112,3 +112,5 @@ Metrics/CyclomaticComplexity:
Max: 15 Max: 15
Metrics/PerceivedComplexity: Metrics/PerceivedComplexity:
Max: 15 Max: 15
Metrics/ParameterLists:
Max: 6

2
Gemfile.lock
View File

@ -1,7 +1,7 @@
PATH PATH
remote: . remote: .
specs: specs:
rabbit_carrots (1.0.6) rabbit_carrots (1.1.0)
bunny (>= 2.22) bunny (>= 2.22)
connection_pool (>= 2.4) connection_pool (>= 2.4)

5
lib/rabbit_carrots/core.rb
View File

@ -36,6 +36,7 @@ module RabbitCarrots
handler_class:, handler_class:,
routing_keys: channel[:routing_keys], routing_keys: channel[:routing_keys],
queue_arguments: channel[:arguments], queue_arguments: channel[:arguments],
exchange_name: channel[:exchange_name],
kill_to_restart_on_standard_error: kill_to_restart_on_standard_error:
) )
end end
@ -76,9 +77,9 @@ module RabbitCarrots
@running = false @running = false
end 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| 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}" logger.info "Listening on QUEUE: #{queue_name} for ROUTING KEYS: #{routing_keys}"
queue = channel.queue(queue_name, durable: true, arguments: queue_arguments) queue = channel.queue(queue_name, durable: true, arguments: queue_arguments)

2
lib/rabbit_carrots/version.rb
View File

@ -1,5 +1,5 @@
# frozen_string_literal: true # frozen_string_literal: true
module RabbitCarrots module RabbitCarrots
VERSION = '1.0.6' VERSION = '1.1.0'
end end