module Queight

# File lib/queight.rb, line 32
def self.current
  options = RabbitMQConfig.configure_from!("RABBITMQ_URL").config
  channel_pool = GlobalConnectionCache.call(options)
  Client.new(channel_pool)
end

# File lib/queight.rb, line 16
def self.default_exchange(message_options = {})
  DefaultExchange.new(message_options)
end

# File lib/queight.rb, line 24
def self.direct(name, message_options = {})
  Exchange.new(:direct, name, message_options)
end

# File lib/queight.rb, line 28
def self.fanout(name, message_options = {})
  Exchange.new(:fanout, name, message_options)
end

# File lib/queight.rb, line 12
def self.queue(name, options = {})
  Queue.new(name, options)
end

# File lib/queight.rb, line 20
def self.topic(name, message_options = {})
  Exchange.new(:topic, name, message_options)
end