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