Contents

require 'spec_helper'

module QueueBus
  describe SubscriptionList do
    describe ".from_redis" do
      it "should return from attributes" do
        mult = {"event_one" => {"class" => "MyClass", "queue_name" => "default", "key" => "event_one", "matcher" => {"bus_event_type" => "event_one"}}, 
                "event_two" => {"class" => "MyClass", "queue_name" => "else",    "key" => "event_two", "matcher" => {"bus_event_type" => "event_two"}}}

        list = SubscriptionList.from_redis(mult)
        list.size.should == 2
        one = list.key("event_one")
        two = list.key("event_two")
        
        one.key.should == "event_one"
        one.key.should == "event_one"
        one.queue_name.should == "default"
        one.class_name.should == "MyClass"
        one.matcher.filters.should == {"bus_event_type" => "event_one"}
        
        two.key.should == "event_two"
        two.key.should == "event_two"
        two.queue_name.should == "else"
        two.class_name.should == "MyClass"
        two.matcher.filters.should == {"bus_event_type" => "event_two"}
      end
    end
    
    describe "#to_redis" do
      it "should generate what to store" do
        list = SubscriptionList.new
        list.add(Subscription.new("default", "key1", "MyClass", {"bus_event_type" => "event_one"}))
        list.add(Subscription.new("else_ok", "key2", "MyClass", {"bus_event_type" => "event_two"}))
        
        hash = list.to_redis
        hash.should == {  "key1" => {"queue_name" => "default", "key" => "key1", "class" => "MyClass", "matcher" => {"bus_event_type" => "event_one"}}, 
                          "key2" => {"queue_name" => "else_ok", "key" => "key2", "class" => "MyClass", "matcher" => {"bus_event_type" => "event_two"}}
                       }
        
      end
    end
  end
end

Version data entries

26 entries across 26 versions & 3 rubygems

Version	Path
queue-bus-0.5.4	spec/subscription_list_spec.rb
queue-bus-0.5.3	spec/subscription_list_spec.rb
sidekiq-bus-0.5.2	spec/subscription_list_spec.rb
queue-bus-0.5.2	spec/subscription_list_spec.rb
queue-bus-0.5.1	spec/subscription_list_spec.rb
queue-bus-0.5.0	spec/subscription_list_spec.rb