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