module Vx::Common::AMQP
Constants
- VERSION
Public Instance Methods
close()
click to toggle source
# File lib/vx/common/amqp.rb, line 44 def close session.close end
config()
click to toggle source
# File lib/vx/common/amqp.rb, line 28 def config @@config end
configure() { |config| ... }
click to toggle source
# File lib/vx/common/amqp.rb, line 24 def configure yield config end
instrument(name, payload) { || ... }
click to toggle source
# File lib/vx/common/amqp.rb, line 57 def instrument(name, payload, &block) if config.debug? STDOUT.puts "name: #{name} payload: #{payload.inspect}" end if config && config.instrumenter config.instrumenter.instrument(name, payload, &block) else yield if block_given? end end
open()
click to toggle source
# File lib/vx/common/amqp.rb, line 36 def open session.open end
open?()
click to toggle source
# File lib/vx/common/amqp.rb, line 40 def open? session.open? end
session()
click to toggle source
# File lib/vx/common/amqp.rb, line 32 def session @@session end
shutdown()
click to toggle source
# File lib/vx/common/amqp.rb, line 48 def shutdown Common::AMQP::Session.shutdown Vx::Common::AMQP::Supervisor::Threaded.shutdown end
shutdown?()
click to toggle source
# File lib/vx/common/amqp.rb, line 53 def shutdown? Common::AMQP::Session.shutdown? end