Contents

module AMQP
  VERSION = '0.5.5'

  DIR = File.expand_path(File.dirname(File.expand_path(__FILE__)))
  $:.unshift DIR
  
  require 'ext/em'
  require 'ext/blankslate'
  
  %w[ buffer spec protocol frame client ].each do |file|
    require "amqp/#{file}"
  end

  class << self
    @logging = false
    attr_accessor :logging
  end

  def self.connect *args
    Client.connect *args
  end

  def self.settings
    @settings ||= {
      :user => 'guest',
      :pass => 'guest',
      :vhost => '/',
      :logging => false
    }
  end

  def self.start *args
    @conn ||= connect *args
  end
  
  def self.stop
    if @conn
      @conn.close{
        yield if block_given?
        @conn = nil
      }
    end
  end
end

Version data entries

2 entries across 2 versions & 2 rubygems

Version	Path
tmm1-amqp-0.5.5	lib/amqp.rb
amqp-0.5.5	lib/amqp.rb