module Vx::Common::AMQP::Consumer::ClassMethods
Public Instance Methods
config()
click to toggle source
# File lib/vx/common/amqp/consumer.rb, line 52 def config Common::AMQP.config end
messages()
click to toggle source
# File lib/vx/common/amqp/testing.rb, line 42 def messages Testing.messages[exchange_name] end
messages_and_options()
click to toggle source
# File lib/vx/common/amqp/testing.rb, line 46 def messages_and_options Testing.messages_and_options[exchange_name] end
session()
click to toggle source
# File lib/vx/common/amqp/consumer.rb, line 48 def session Common::AMQP.session end
shutdown()
click to toggle source
# File lib/vx/common/amqp/consumer.rb, line 44 def shutdown Common::AMQP.shutdown end
shutdown?()
click to toggle source
# File lib/vx/common/amqp/consumer.rb, line 40 def shutdown? Common::AMQP.shutdown? end
Private Instance Methods
declare_exchange()
click to toggle source
# File lib/vx/common/amqp/consumer.rb, line 58 def declare_exchange session.declare_exchange(exchange_name, exchange_options) end
declare_queue()
click to toggle source
# File lib/vx/common/amqp/consumer.rb, line 62 def declare_queue session.declare_queue(queue_name, queue_options) end