Module: ActiveMessage

Defined in:
lib/active_message.rb,
lib/active_message/broker.rb,
lib/active_message/logger.rb,
lib/active_message/worker.rb,
lib/active_message/version.rb,
lib/active_message/consumer.rb,
lib/active_message/configuration.rb

Defined Under Namespace

Modules: Configuration, Consumer Classes: Broker, Logger, UnknownAttributeError, Worker

Constant Summary collapse

VERSION = 
"0.0.3"

Class Method Summary collapse

Class Method Details

.broker ⇒ Object 



32
33
34
 
# File 'lib/active_message.rb', line 32

def self.broker
  @broker
end

.connect(config = ActiveMessage::Configuration) ⇒ Object 



24
25
26
27
28
29
30
 
# 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 ⇒ Object 



36
37
38
 
# File 'lib/active_message.rb', line 36

def self.connected
  @connected
end

.consumers ⇒ Object 



20
21
22
 
# File 'lib/active_message.rb', line 20

def self.consumers
  @consumers ||= []
end

.publish(*args) ⇒ Object 



40
41
42
 
# File 'lib/active_message.rb', line 40

def self.publish(*args)
  self.broker.publish(*args)
end

.register_consumer(klass) ⇒ Object 



15
16
17
18
 
# File 'lib/active_message.rb', line 15

def self.register_consumer(klass)
  ActiveMessage::Logger.debug "Registered Consumer: #{klass.name}"
  self.consumers << klass
end

.version ⇒ Object 



44
45
46
 
# File 'lib/active_message.rb', line 44

def self.version
  ActiveMessage::VERSION
end