From 7c4c7ea08f80e687b24ba5ab48ec9aa0d61233d8 Mon Sep 17 00:00:00 2001 From: Muhammad Nawzad Date: Wed, 6 Dec 2023 14:26:16 +0300 Subject: [PATCH] Renames `event_bus_exchange_name` to `rabbitmq_exchange_name` for consistency --- README.md | 2 +- lib/rabbit_carrots/configuration.rb | 2 +- lib/rabbit_carrots/tasks/rmq.rake | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) diff --git a/README.md b/README.md index 50ead91..9c685f6 100644 --- a/README.md +++ b/README.md @@ -32,7 +32,7 @@ RabbitCarrots.configure do |c| c.rabbitmq_user = ENV.fetch('RABBITMQ__USER', nil) c.rabbitmq_password = ENV.fetch('RABBITMQ__PASSWORD', nil) c.rabbitmq_vhost = ENV.fetch('RABBITMQ__VHOST', nil) - c.event_bus_exchange_name = ENV.fetch('EVENTBUS__EXCHANGE_NAME', nil) + c.rabbitmq_exchange_name = ENV.fetch('RABBITMQ__EXCHANGE_NAME', nil) c.routing_key_mappings = [ { routing_keys: ['RK1', 'RK2'], queue: 'QUEUE_NAME', handler: 'CLASS HANDLER IN STRING' }, { routing_keys: ['RK1', 'RK2'], queue: 'QUEUE_NAME', handler: 'CLASS HANDLER IN STRING' } diff --git a/lib/rabbit_carrots/configuration.rb b/lib/rabbit_carrots/configuration.rb index b861a1e..410561a 100644 --- a/lib/rabbit_carrots/configuration.rb +++ b/lib/rabbit_carrots/configuration.rb @@ -9,6 +9,6 @@ module RabbitCarrots end class Configuration - attr_accessor :rabbitmq_host, :rabbitmq_port, :rabbitmq_user, :rabbitmq_password, :rabbitmq_vhost, :routing_key_mappings, :event_bus_exchange_name + attr_accessor :rabbitmq_host, :rabbitmq_port, :rabbitmq_user, :rabbitmq_password, :rabbitmq_vhost, :routing_key_mappings, :rabbitmq_exchange_name end end diff --git a/lib/rabbit_carrots/tasks/rmq.rake b/lib/rabbit_carrots/tasks/rmq.rake index a8c5830..541f45b 100644 --- a/lib/rabbit_carrots/tasks/rmq.rake +++ b/lib/rabbit_carrots/tasks/rmq.rake @@ -36,7 +36,7 @@ end def run_task(queue_name:, handler_class:, routing_keys:, queue_arguments: {}) RabbitCarrots::Connection.instance.channel.with do |channel| - exchange = channel.topic(RabbitCarrots.configuration.event_bus_exchange_name, durable: true) + exchange = channel.topic(RabbitCarrots.configuration.rabbitmq_exchange_name, durable: true) Rails.logger.info "Listening on QUEUE: #{queue_name} for ROUTING KEYS: #{routing_keys}" queue = channel.queue(queue_name, durable: true, arguments: queue_arguments)