module ActiveMessage

Constants

VERSION

Public Class Methods

broker() click to toggle source 
# File lib/active_message.rb, line 32
def self.broker
  @broker
end
connect(config = ActiveMessage::Configuration) click to toggle source 
# File lib/active_message.rb, line 24
def self.connect(config = ActiveMessage::Configuration)
  ActiveMessage::Logger.debug "Connecting to AMQP ...."
  @broker               = ActiveMessage::Broker.instance
  @broker.connect(config)
  @connected            = true
  ActiveMessage::Logger.debug "Connected to AMQP ...."
end
connected() click to toggle source 
# File lib/active_message.rb, line 36
def self.connected
  @connected
end
consumers() click to toggle source 
# File lib/active_message.rb, line 20
def self.consumers
  @consumers ||= []
end
publish(*args) click to toggle source 
# File lib/active_message.rb, line 40
def self.publish(*args)
  self.broker.publish(*args)
end
register_consumer(klass) click to toggle source 
# File lib/active_message.rb, line 15
def self.register_consumer(klass)
  ActiveMessage::Logger.debug "Registered Consumer: #{klass.name}"
  self.consumers << klass
end
version() click to toggle source 
# File lib/active_message.rb, line 44
def self.version
  ActiveMessage::VERSION
end