module Queight
Constants
- GlobalConnectionCache
- VERSION
Public Class Methods
current()
click to toggle source
# 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
default_exchange(message_options = {})
click to toggle source
# File lib/queight.rb, line 16 def self.default_exchange(message_options = {}) DefaultExchange.new(message_options) end
direct(name, message_options = {})
click to toggle source
# File lib/queight.rb, line 24 def self.direct(name, message_options = {}) Exchange.new(:direct, name, message_options) end
fanout(name, message_options = {})
click to toggle source
# File lib/queight.rb, line 28 def self.fanout(name, message_options = {}) Exchange.new(:fanout, name, message_options) end
queue(name, options = {})
click to toggle source
# File lib/queight.rb, line 12 def self.queue(name, options = {}) Queue.new(name, options) end
topic(name, message_options = {})
click to toggle source
# File lib/queight.rb, line 20 def self.topic(name, message_options = {}) Exchange.new(:topic, name, message_options) end