Contents

require 'spec_helper'

describe Sidekiq::LimitFetch do
  before :each do
    Sidekiq.redis do |it|
      it.del 'queue:queue1'
      it.rpush 'queue:queue1', 'task1'
      it.rpush 'queue:queue1', 'task2'
      it.expire 'queue:queue1', 30
    end
  end

  subject { described_class.new options }
  let(:options) {{ queues: queues, limits: limits, global: global }}
  let(:queues) { %w(queue1 queue1 queue2 queue2) }
  let(:limits) {{ 'queue1' => 1, 'queue2' => 2 }}
  
  shared_examples_for :strategy do
    it 'should acquire lock on queue for execution' do
      work = subject.retrieve_work
      work.queue_name.should == 'queue1'
      work.message.should == 'task1'

      subject.retrieve_work.should_not be
      work.requeue

      work = subject.retrieve_work
      work.message.should == 'task2'

      subject.retrieve_work.should_not be
      work.acknowledge

      work = subject.retrieve_work
      work.message.should == 'task1'
    end
  end

  context 'global' do
    let(:global) { true }
    it_behaves_like :strategy
  end

  context 'local' do
    let(:global) { false }
    it_behaves_like :strategy
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
sidekiq-limit_fetch-1.1	spec/sidekiq/limit_fetch_spec.rb
sidekiq-limit_fetch-1.0	spec/sidekiq/limit_fetch_spec.rb
sidekiq-limit_fetch-0.9	spec/sidekiq/limit_fetch_spec.rb
sidekiq-limit_fetch-0.8	spec/sidekiq/limit_fetch_spec.rb
sidekiq-limit_fetch-0.7	spec/sidekiq/limit_fetch_spec.rb
sidekiq-limit_fetch-0.6	spec/sidekiq/limit_fetch_spec.rb