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

Accepts queue argument

Browse Source
This commit is contained in:
Brusk Awat 2023-03-29 11:53:48 +03:00
parent 189851ef6e
commit b90ef2752b
Signed by: broosk1993
GPG Key ID: 5D20F7E02649F74E
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
lib/rabbit_carrots/tasks/rmq.rake
View File

@ -18,7 +18,7 @@ namespace :rabbit_carrots do
raise "#{handler_class.name} must respond to `handle!`" unless handler_class.respond_to?(:handle!)
run_task(queue_name: channel[:queue], handler_class:, routing_keys: channel[:routing_keys])
run_task(queue_name: channel[:queue], handler_class:, routing_keys: channel[:routing_keys], queue_arguments: channel[:arguments])
end
# Infinite loop to keep the process running
@ -28,12 +28,12 @@ namespace :rabbit_carrots do
end
end
def run_task(queue_name:, handler_class:, routing_keys:)
def run_task(queue_name:, queue_arguments: {}, handler_class:, routing_keys:)
RabbitCarrots::Connection.instance.channel.with do |channel|
exchange = channel.topic(RabbitCarrots.configuration.event_bus_exchange_name, durable: true)
Rails.logger.info "Listening on QUEUE: #{queue_name} for ROUTING KEYS: #{routing_keys}"
queue = channel.queue(queue_name, durable: true)
queue = channel.queue(queue_name, durable: true, arguments: queue_arguments)
routing_keys.map(&:strip).each { |k| queue.bind(exchange, routing_key: k) }

2
lib/rabbit_carrots/version.rb
View File

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