Module: Lolitra

Includes:
Log4r
Defined in:
lib/lolitra/version.rb,
lib/lolitra/handler_base.rb,
lib/lolitra/rabbitmq_bus.rb

Defined Under Namespace

Modules: Message, MessageHandler Classes: FayeBus, MessageHandlerManager, RabbitmqBus

Constant Summary collapse

VERSION = 
"0.2.4"
@@logger = 
Logger.new 'lolitra'

Class Method Summary collapse

Class Method Details

.disconnect(&block) ⇒ Object 



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

def self.disconnect(&block)
  Lolitra::MessageHandlerManager.disconnect(&block)
end

.log_exception(e) ⇒ Object 



23
24
25
26
 
# File 'lib/lolitra/handler_base.rb', line 23

def self.log_exception(e)
  logger.error(e.message)
  logger.error(e.backtrace.join("\n\t"))
end

.logger ⇒ Object 



15
16
17
 
# File 'lib/lolitra/handler_base.rb', line 15

def self.logger
  @@logger
end

.logger=(new_logger) ⇒ Object 



19
20
21
 
# File 'lib/lolitra/handler_base.rb', line 19

def self.logger=(new_logger)
  @@logger = new_logger
end

.process_deadletters(subscriber) ⇒ Object 



46
47
48
 
# File 'lib/lolitra/handler_base.rb', line 46

def self.process_deadletters(subscriber)
  Lolitra::MessageHandlerManager.instance.process_deadletters(subscriber)
end

.publish(message) ⇒ Object 



28
29
30
 
# File 'lib/lolitra/handler_base.rb', line 28

def self.publish(message)
  Lolitra::MessageHandlerManager.publish(message)
end

.purge_deadletters(subscriber) ⇒ Object 



54
55
56
 
# File 'lib/lolitra/handler_base.rb', line 54

def self.purge_deadletters(subscriber)
  Lolitra::MessageHandlerManager.instance.purge_deadletters(subscriber)
end

.remove_next_deadletter(subscriber) ⇒ Object 



50
51
52
 
# File 'lib/lolitra/handler_base.rb', line 50

def self.remove_next_deadletter(subscriber)
  Lolitra::MessageHandlerManager.instance.remove_next_deadletter(subscriber)
end

.subscribers ⇒ Object 



40
41
42
43
44
 
# File 'lib/lolitra/handler_base.rb', line 40

def self.subscribers
  Lolitra::MessageHandlerManager.instance.subscribers.collect do |subscriber|
    subscriber.name
  end
end

.unsubscribe(handler_class, &block) ⇒ Object 



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

def self.unsubscribe(handler_class, &block)
  Lolitra::MessageHandlerManager.unsubscribe(handler_class, &block)
end