diff --git a/lib/rabbit_carrots/tasks/rmq.rake b/lib/rabbit_carrots/tasks/rmq.rake index 63f2583..7ef78a1 100644 --- a/lib/rabbit_carrots/tasks/rmq.rake +++ b/lib/rabbit_carrots/tasks/rmq.rake @@ -29,7 +29,7 @@ namespace :rmq do end def run_task(queue_name:, handler_class:, routing_keys:) - RabbitConnection.instance.channel.with do |channel| + 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}" diff --git a/lib/rabbit_carrots/version.rb b/lib/rabbit_carrots/version.rb index 61917ab..2f5e005 100644 --- a/lib/rabbit_carrots/version.rb +++ b/lib/rabbit_carrots/version.rb @@ -1,5 +1,5 @@ # frozen_string_literal: true module RabbitCarrots - VERSION = "0.1.7" + VERSION = "0.1.8" end