module Lapine
Constants
- VERSION
Public Class Methods
add_connection(name, properties)
click to toggle source
# File lib/lapine.rb, line 13 def self.add_connection(name, properties) config.connection_properties[name] = properties end
add_exchange(name, properties)
click to toggle source
# File lib/lapine.rb, line 17 def self.add_exchange(name, properties) connection = properties[:connection] raise UndefinedConnection.new("No connection for #{name}, properties: #{properties}") unless connection raise UndefinedConnection.new("No connection properties for #{name}, properties: #{properties}") unless config.connection_properties[connection] config.exchange_properties[name] = properties end
close_connections!()
click to toggle source
# File lib/lapine.rb, line 35 def self.close_connections! config.close_connections! end
config()
click to toggle source
# File lib/lapine.rb, line 9 def self.config @config ||= Configuration.new end
find_exchange(name)
click to toggle source
# File lib/lapine.rb, line 24 def self.find_exchange(name) exchange = config.exchanges[name] return exchange.exchange if (exchange && exchange.connected?) exchange_configuration = config.exchange_properties[name] raise UndefinedExchange.new("No exchange configuration for #{name}") unless exchange_configuration config.exchanges[name] = Lapine::Exchange.new(name, exchange_configuration) config.exchanges[name].exchange end