Sha256: 89c9858d348627aa302bb61939540673b5ca5200dc3c04cc41e8240f7b77b763

Contents?: true

Size: 781 Bytes

Versions: 19

Compression:

Stored size: 781 Bytes

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