spec/resque-restriction/job_spec.rb in resque-restriction-0.1.0 vs spec/resque-restriction/job_spec.rb in resque-restriction-0.2.0
- old
+ new
@@ -1,17 +1,26 @@
require File.join(File.dirname(__FILE__) + '/../spec_helper')
describe Resque::Job do
- it "should repush restrictioin queue when reserve" do
+ it "should repush restriction queue when reserve" do
Resque.redis.flushall
- Resque.push('restriction', :class => 'OneHourRestrictionJob', :args => 'any args')
+ Resque.push('restriction', :class => 'OneHourRestrictionJob', :args => ['any args'])
Resque::Job.reserve('restriction').should be_nil
- Resque::Job.reserve('normal').should == Resque::Job.new('normal', {'class' => 'OneHourRestrictionJob', 'args' => 'any args'})
+ Resque::Job.reserve('normal').should == Resque::Job.new('normal', {'class' => 'OneHourRestrictionJob', 'args' => ['any args']})
Resque::Job.reserve('normal').should be_nil
end
+ it "should push back to restriction queue when still restricted" do
+ Resque.redis.flushall
+ Resque.redis.set(OneHourRestrictionJob.redis_key(:per_hour), -1)
+ Resque.push('restriction', :class => 'OneHourRestrictionJob', :args => ['any args'])
+ Resque::Job.reserve('restriction').should be_nil
+ Resque.pop('restriction').should == {'class' => 'OneHourRestrictionJob', 'args' => ['any args']}
+ Resque::Job.reserve('normal').should be_nil
+ end
+
it "should not repush when reserve normal queue" do
- Resque.push('normal', :class => 'OneHourRestrictionJob', :args => 'any args')
- Resque::Job.reserve('normal').should == Resque::Job.new('normal', {'class' => 'OneHourRestrictionJob', 'args' => 'any args'})
+ Resque.push('normal', :class => 'OneHourRestrictionJob', :args => ['any args'])
+ Resque::Job.reserve('normal').should == Resque::Job.new('normal', {'class' => 'OneHourRestrictionJob', 'args' => ['any args']})
Resque::Job.reserve('normal').should be_nil
end
end