Class: MessageBus::MessageHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/message_bus/message_handler.rb

Class Method Summary collapse

Class Method Details

.call(site_id, name, data, current_user_id) ⇒ Object 



16
17
18
19
20
21
22
23
 
# File 'lib/message_bus/message_handler.rb', line 16

def self.call(site_id, name, data, current_user_id)
  begin
    MessageBus.on_connect.call(site_id) if MessageBus.on_connect
    @@handlers[name].call(data,current_user_id)
  ensure
    MessageBus.on_disconnect.call(site_id) if MessageBus.on_disconnect
  end
end

.handle(name, &blk) ⇒ Object

Raises:

  • (ArgumentError) 


8
9
10
11
12
13
14
 
# File 'lib/message_bus/message_handler.rb', line 8

def self.handle(name,&blk)
  raise ArgumentError.new("expecting block") unless block_given?
  raise ArgumentError.new("name") unless name

  @@handlers ||= {}
  @@handlers[name] = blk
end

.load_handlers(path) ⇒ Object 



2
3
4
5
6
 
# File 'lib/message_bus/message_handler.rb', line 2

def self.load_handlers(path)
  Dir.glob("#{path}/*.rb").each do |f|
    load "#{f}"
  end
end