Contents

require File.dirname(__FILE__) + '/../test_helper'

class SampleWorker < Refinery::Worker
  attr_reader :message
  def execute(message)
    @message = message
  end
end

class WorkerTest < Test::Unit::TestCase
  context "a worker" do
    setup do
      daemon = stub('daemon')
      @worker = SampleWorker.new(daemon)
      @message = {'test' => 'value'}
    end
    should "run" do
      @worker.run(@message)
      assert_equal @message, @worker.message
    end
    should "provide a data store" do
      options = {:bucket => 'bucket'}
      
      data_store = stub('data store')
      
      Moneta::S3.expects(:new).with(
        :access_key_id => 'aki',  
        :secret_access_key => 'sak',
        :bucket => options[:bucket],
        :multi_thread => true
      ).returns(data_store)
      
      setup_default_config
      assert_not_nil @worker.data_store(options)
    end
    should "provide a queue" do
      queue = stub('queue')
      queue_provider = stub('queue provider')
      queue_provider.expects(:queue).with('a_queue').returns(queue)
      @worker.expects(:queue_provider).returns(queue_provider)      
      assert_not_nil @worker.queue('a_queue')
    end
  end
end

Version data entries

51 entries across 51 versions & 2 rubygems

Version	Path
aeden-refinery-0.10.0	test/unit/worker_test.rb
aeden-refinery-0.10.1	test/unit/worker_test.rb
aeden-refinery-0.10.10	test/unit/worker_test.rb
aeden-refinery-0.10.2	test/unit/worker_test.rb
aeden-refinery-0.10.3	test/unit/worker_test.rb
aeden-refinery-0.10.5	test/unit/worker_test.rb
aeden-refinery-0.10.6	test/unit/worker_test.rb
aeden-refinery-0.10.8	test/unit/worker_test.rb
aeden-refinery-0.9.1	test/unit/worker_test.rb
aeden-refinery-0.9.10	test/unit/worker_test.rb
aeden-refinery-0.9.11	test/unit/worker_test.rb
aeden-refinery-0.9.12	test/unit/worker_test.rb
aeden-refinery-0.9.13	test/unit/worker_test.rb
aeden-refinery-0.9.14	test/unit/worker_test.rb
aeden-refinery-0.9.15	test/unit/worker_test.rb
aeden-refinery-0.9.2	test/unit/worker_test.rb
aeden-refinery-0.9.4	test/unit/worker_test.rb
aeden-refinery-0.9.5	test/unit/worker_test.rb
aeden-refinery-0.9.6	test/unit/worker_test.rb
aeden-refinery-0.9.7	test/unit/worker_test.rb