Contents

require File.dirname(__FILE__) + '/../test_helper'
class ProcessorTest < Test::Unit::TestCase
  context "a processor" do
    setup do
      @server = stub('Server')
      @settings = {
        'workers' => {
          'initial' => 1
        }
      }
      
      @waiting_queue = stub('Queue(waiting)')
      @error_queue = stub('Queue(error)')
      @done_queue = stub('Queue(done)')
      
      provider = stub('QueueProvider')
      if defined?(Typica)
        Typica::Sqs::QueueService.stubs(:new).returns(provider)
      else
        RightAws::SqsGen2.stubs(:new).returns(provider)
      end
      provider.stubs(:queue).with('sample_waiting').returns(@waiting_queue)
      provider.stubs(:queue).with('sample_error').returns(@error_queue)
      provider.stubs(:queue).with('sample_done').returns(@done_queue)
    end
    should "initialize" do
      assert_nothing_raised do
        @waiting_queue.stubs(:receive)
        Refinery::Processor.new(@server, 'sample', @settings)
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 2 rubygems

Version	Path
aeden-refinery-0.10.10	test/unit/processor_test.rb
refinery-0.12.1	test/unit/processor_test.rb
refinery-0.12.0	test/unit/processor_test.rb
refinery-0.11.0	test/unit/processor_test.rb
refinery-0.10.11	test/unit/processor_test.rb
refinery-0.10.10	test/unit/processor_test.rb
refinery-0.10.9	test/unit/processor_test.rb