module Evrone::Common::AMQP::Consumer::ClassMethods

Public Instance Methods

config() click to toggle source
# File lib/evrone/common/amqp/consumer.rb, line 52
def config
  Common::AMQP.config
end
messages() click to toggle source
# File lib/evrone/common/amqp/testing.rb, line 42
def messages
  Testing.messages[exchange_name]
end
messages_and_options() click to toggle source
# File lib/evrone/common/amqp/testing.rb, line 46
def messages_and_options
  Testing.messages_and_options[exchange_name]
end
session() click to toggle source
# File lib/evrone/common/amqp/consumer.rb, line 48
def session
  Common::AMQP.session
end
shutdown() click to toggle source
# File lib/evrone/common/amqp/consumer.rb, line 44
def shutdown
  Common::AMQP.shutdown
end
shutdown?() click to toggle source
# File lib/evrone/common/amqp/consumer.rb, line 40
def shutdown?
  Common::AMQP.shutdown?
end

Private Instance Methods

declare_exchange() click to toggle source
# File lib/evrone/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/evrone/common/amqp/consumer.rb, line 62
def declare_queue
  session.declare_queue(queue_name, queue_options)
end