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