From 274bec3e68dc401f93bf356566ffaf8b11c82ea1 Mon Sep 17 00:00:00 2001 From: Ari Karim Date: Sun, 18 Jan 2026 10:08:27 +0300 Subject: [PATCH] Add exchange_name parameter to run_task method for enhanced configuration flexibility --- lib/rabbit_carrots/core.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/rabbit_carrots/core.rb b/lib/rabbit_carrots/core.rb index 0604575..10edffb 100644 --- a/lib/rabbit_carrots/core.rb +++ b/lib/rabbit_carrots/core.rb @@ -77,7 +77,7 @@ 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(exchange_name || RabbitCarrots.configuration.rabbitmq_exchange_name, durable: true)