Sha256: c8cb17399235817ee40b5e3b63dafbd43697530142bf8e643b3b3d9c9fe501a6
Contents?: true
Size: 1.78 KB
Versions: 16
Compression:
Stored size: 1.78 KB
Contents
require 'spec_helper'
module ResqueBus
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
16 entries across 16 versions & 1 rubygems