Contents

require 'spec_helper'
require 'message_bus'

describe MessageBus::MessageHandler do

  it "should properly register message handlers" do
    MessageBus::MessageHandler.handle "/hello" do |m|
      m
    end
    MessageBus::MessageHandler.call("site","/hello", "world", 1).should == "world"
  end

  it "should correctly load message handlers" do
    MessageBus::MessageHandler.load_handlers("#{File.dirname(__FILE__)}/handlers")
    MessageBus::MessageHandler.call("site","/dupe", "1", 1).should == "11"
  end

  it "should allow for a connect / disconnect callback" do
    MessageBus::MessageHandler.handle "/channel" do |m|
      m
    end

    connected = false
    disconnected = false

    MessageBus.on_connect do |site_id|
      connected = true
    end
    MessageBus.on_disconnect do |site_id|
      disconnected = true
    end

    MessageBus::MessageHandler.call("site_id", "/channel", "data", 1)

    connected.should == true
    disconnected.should == true

  end
end

Version data entries

25 entries across 25 versions & 1 rubygems

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