Module: Vx::Common::AMQP::Consumer::ClassMethods

Includes:
Configuration, Publish, Subscribe, Instrument
Defined in:
lib/vx/common/amqp/consumer.rb,
lib/vx/common/amqp/testing.rb

Instance Method Summary collapse

Methods included from Instrument

#instrument

Methods included from Subscribe

#pop, #start, #subscribe

Methods included from Publish

#publish, #serialize_message

Methods included from Configuration

#ack, #bind_options, #consumer_configuration, #consumer_id, #consumer_name, #content_type, #headers, #model, #reset_consumer_configuration!, #routing_key

Instance Method Details

#config ⇒ Object 



52
53
54
 
# File 'lib/vx/common/amqp/consumer.rb', line 52

def config
  Common::AMQP.config
end

#messages ⇒ Object 



42
43
44
 
# File 'lib/vx/common/amqp/testing.rb', line 42

def messages
  Testing.messages[exchange_name]
end

#messages_and_options ⇒ Object 



46
47
48
 
# File 'lib/vx/common/amqp/testing.rb', line 46

def messages_and_options
  Testing.messages_and_options[exchange_name]
end

#session ⇒ Object 



48
49
50
 
# File 'lib/vx/common/amqp/consumer.rb', line 48

def session
  Common::AMQP.session
end

#shutdown ⇒ Object 



44
45
46
 
# File 'lib/vx/common/amqp/consumer.rb', line 44

def shutdown
  Common::AMQP.shutdown
end

#shutdown? ⇒ Boolean

Returns:

  • (Boolean) 


40
41
42
 
# File 'lib/vx/common/amqp/consumer.rb', line 40

def shutdown?
  Common::AMQP.shutdown?
end