diff --git a/app/models/manageiq/providers/vmware/cloud_manager/event_catcher/stream.rb b/app/models/manageiq/providers/vmware/cloud_manager/event_catcher/stream.rb index 4f7e5c2b2..7ad83b8ef 100644 --- a/app/models/manageiq/providers/vmware/cloud_manager/event_catcher/stream.rb +++ b/app/models/manageiq/providers/vmware/cloud_manager/event_catcher/stream.rb @@ -1,5 +1,3 @@ -require 'bunny' - # Listens to RabbitMQ events class ManageIQ::Providers::Vmware::CloudManager::EventCatcher::Stream include Vmdb::Logging @@ -22,6 +20,7 @@ def self.test_amqp_connection(options = {}) end def self.connect(connection_options = {}) + require 'bunny' Bunny.new(connection_options) end @@ -70,6 +69,7 @@ def connection end def initialize_queues(channel) + require 'bunny' @queues = {} @options[:queues].each do |queue_name| begin