Contents

class JobQueue::TestAdapter
  def initialize(options = {})
    @queue = []
  end
  
  def put(string)
    @queue << string
  end
  
  def subscribe(error_report, &block)
    loop do
      begin
        sleep 0.1 if @queue.empty?
        yield @queue.shift
      rescue
        error_report.call(job.body, e)
      end
    end
  end
end

Version data entries

8 entries across 8 versions & 2 rubygems

Version	Path
mloughran-job_queue-0.0.4	lib/job_queue/adapters/test_adapter.rb
mloughran-job_queue-0.0.5	lib/job_queue/adapters/test_adapter.rb
mloughran-job_queue-0.0.6	lib/job_queue/adapters/test_adapter.rb
mloughran-job_queue-0.0.7	lib/job_queue/adapters/test_adapter.rb
newbamboo-job_queue-0.0.5	lib/job_queue/adapters/test_adapter.rb
newbamboo-job_queue-0.0.6	lib/job_queue/adapters/test_adapter.rb
newbamboo-job_queue-0.0.7	lib/job_queue/adapters/test_adapter.rb
newbamboo-job_queue-0.0.8	lib/job_queue/adapters/test_adapter.rb