Contents

require 'spec_helper'
require 'resque/rate_limited_queue'

class RateLimitedTestQueue
end

describe Resque::Plugins::RateLimitedQueue::UnPause do
  describe 'perform' do
    it 'unpauses the queue' do
      RateLimitedTestQueue.should_receive(:un_pause)
      Resque::Plugins::RateLimitedQueue::UnPause.perform(RateLimitedTestQueue)
    end
  end

  describe 'enqueue' do
    before { Resque.stub(:respond_to?).and_return(true) }
    context 'with no queue defined' do
      it 'does not queue the job' do
        Resque.should_not_receive(:enqueue_at_with_queue)
        Resque::Plugins::RateLimitedQueue::UnPause.enqueue(Time.now, RateLimitedTestQueue)
      end
    end

    context 'with queue defined' do
      before { Resque::Plugins::RateLimitedQueue::UnPause.queue = :queue_name }
      it 'queues the job' do
        Resque.should_receive(:enqueue_at_with_queue).with(
          :queue_name,
          nil,
          Resque::Plugins::RateLimitedQueue::UnPause,
          RateLimitedTestQueue)

        Resque::Plugins::RateLimitedQueue::UnPause.enqueue(nil, RateLimitedTestQueue)
      end
    end
  end

  describe 'class_from_string' do
    it 'converts unqualified classes' do
      expect(Resque::Plugins::RateLimitedQueue::UnPause.class_from_string(RateLimitedTestQueue.to_s))
        .to eq(RateLimitedTestQueue)
    end
    it 'converts qualified classes' do
      expect(Resque::Plugins::RateLimitedQueue::UnPause.class_from_string(Resque::Plugins::RateLimitedQueue::UnPause.to_s))
        .to eq(Resque::Plugins::RateLimitedQueue::UnPause)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
resque-rate_limited_queue-1.0.4	spec/rate_limited_un_pause_spec.rb