Contents

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

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

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

  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


end

Version data entries

27 entries across 27 versions & 1 rubygems

Version	Path
message_bus-1.1.1	lib/message_bus/message_handler.rb
message_bus-1.1.0	lib/message_bus/message_handler.rb
message_bus-1.0.16	lib/message_bus/message_handler.rb
message_bus-1.0.15	lib/message_bus/message_handler.rb
message_bus-1.0.14	lib/message_bus/message_handler.rb
message_bus-1.0.13	lib/message_bus/message_handler.rb
message_bus-1.0.12	lib/message_bus/message_handler.rb
message_bus-1.0.11	lib/message_bus/message_handler.rb
message_bus-1.0.10	lib/message_bus/message_handler.rb
message_bus-1.0.9	lib/message_bus/message_handler.rb
message_bus-1.0.8	lib/message_bus/message_handler.rb
message_bus-1.0.7	lib/message_bus/message_handler.rb
message_bus-1.0.6	lib/message_bus/message_handler.rb
message_bus-1.0.5	lib/message_bus/message_handler.rb
message_bus-1.0.4	lib/message_bus/message_handler.rb
message_bus-1.0.3	lib/message_bus/message_handler.rb
message_bus-1.0.2	lib/message_bus/message_handler.rb
message_bus-1.0.1	lib/message_bus/message_handler.rb
message_bus-1.0.0	lib/message_bus/message_handler.rb
message_bus-0.9.6	lib/message_bus/message_handler.rb