Uses the correct class for connection

This commit is contained in:
Brusk Awat 2022-12-01 21:31:06 +03:00
parent d032754f11
commit 7ad8ae050d
Signed by: broosk1993
GPG Key ID: 5D20F7E02649F74E
2 changed files with 2 additions and 2 deletions

View File

@ -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}"

View File

@ -1,5 +1,5 @@
# frozen_string_literal: true
module RabbitCarrots
VERSION = "0.1.7"
VERSION = "0.1.8"
end