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)')
      
      Refinery::Daemon.any_instance.stubs(:queue).with(
      'sample_waiting').returns(@waiting_queue)
      Refinery::Daemon.any_instance.stubs(:queue).with(
      'sample_error').returns(@error_queue)
      Refinery::Daemon.any_instance.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

13 entries across 13 versions & 2 rubygems

Version	Path
aeden-refinery-0.10.0	test/unit/processor_test.rb
aeden-refinery-0.10.1	test/unit/processor_test.rb
aeden-refinery-0.10.2	test/unit/processor_test.rb
aeden-refinery-0.10.3	test/unit/processor_test.rb
aeden-refinery-0.10.5	test/unit/processor_test.rb
aeden-refinery-0.10.6	test/unit/processor_test.rb
refinery-0.10.0	test/unit/processor_test.rb
refinery-0.10.1	test/unit/processor_test.rb
refinery-0.10.2	test/unit/processor_test.rb
refinery-0.10.3	test/unit/processor_test.rb
refinery-0.10.4	test/unit/processor_test.rb
refinery-0.10.5	test/unit/processor_test.rb
refinery-0.10.6	test/unit/processor_test.rb