spec/queues_spec.rb in sidekiq-dynamic-queues-0.5.2 vs spec/queues_spec.rb in sidekiq-dynamic-queues-0.5.3

@@ -6,11 +6,12 @@
   Fetch = Sidekiq::DynamicQueues::Fetch
   
   def watch_queues(*queues)
     Sidekiq.redis do |r|
       queues.each {|q| r.sadd('queues', q) }
-    end    
+      r.del('queues') if queues.size == 0
+    end
   end
   
   before(:each) do
     SomeJob.sidekiq_options('retry' => false, 'queue' => 'default')
     SomeJob.result = nil
@@ -89,9 +90,15 @@
 
     SFTO = Sidekiq::Fetcher::TIMEOUT
     
     before(:each) do
       watch_queues(*%w[high_x foo high_y superhigh_z])
+    end
+    
+    it "uses default when wildcard empty" do
+      watch_queues()
+      fetch = Fetch.new(:queues => %w[*], :strict => true)
+      fetch.queues_cmd.should eq ["queue:default", SFTO]
     end
 
     it "can specify simple queues" do
       fetch = Fetch.new(:queues => %w[foo], :strict => true)
       fetch.queues_cmd.should eq ["queue:foo", SFTO]