Contents

require 'helper'
require 'sidekiq/processor'

class TestProcessor < MiniTest::Unit::TestCase
  describe 'with mock setup' do
    before do
      $invokes = 0
      $errors = []
      @boss = MiniTest::Mock.new
      Celluloid.logger = nil
      Sidekiq.redis = REDIS
    end

    class MockWorker
      include Sidekiq::Worker
      def perform(args)
        raise "kerboom!" if args == 'boom'
        $invokes += 1
      end
    end

    it 'processes as expected' do
      msg = { 'class' => MockWorker.to_s, 'args' => ['myarg'] }
      processor = ::Sidekiq::Processor.new(@boss)
      @boss.expect(:processor_done!, nil, [processor])
      processor.process(msg, 'default')
      @boss.verify
      assert_equal 1, $invokes
      assert_equal 0, $errors.size
    end
  end
end

Version data entries

19 entries across 19 versions & 2 rubygems

Version	Path
sidekiq-2.0.3	test/test_processor.rb
sidekiq-2.0.2	test/test_processor.rb
sidekiq-2.0.1	test/test_processor.rb
sidekiq-2.0.0	test/test_processor.rb
kulesa-sidekiq-1.2.3	test/test_processor.rb
kulesa-sidekiq-1.2.2	test/test_processor.rb
sidekiq-1.2.1	test/test_processor.rb
sidekiq-1.2.0	test/test_processor.rb
sidekiq-1.1.4	test/test_processor.rb
sidekiq-1.1.3	test/test_processor.rb
sidekiq-1.1.2	test/test_processor.rb
sidekiq-1.1.1	test/test_processor.rb
sidekiq-1.1.0	test/test_processor.rb
sidekiq-1.0.0	test/test_processor.rb
sidekiq-0.11.2	test/test_processor.rb
sidekiq-0.11.1	test/test_processor.rb
sidekiq-0.11.0	test/test_processor.rb
sidekiq-0.10.1	test/test_processor.rb
sidekiq-0.10.0	test/test_processor.rb