class MessageBus::MessageHandler

Public Class Methods

call(site_id, name, data, current_user_id) click to toggle source
# 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) click to toggle source
# 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) click to toggle source
# 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