Contents

require 'resque-bus'
require 'resque'
require 'resque/scheduler'

def reset_test_adapter
  QueueBus.send(:reset)
  QueueBus.adapter = QueueBus::Adapters::Resque.new
end

def adapter_under_test_class
  QueueBus::Adapters::Resque
end

def adapter_under_test_symbol
  :resque
end

def perform_next_job(worker, &block)
  return unless job = worker.reserve
  worker.perform(job, &block)
  worker.done_working
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
resque-bus-0.7.0	spec/adapter/support.rb
resque-bus-0.6.1	spec/adapter/support.rb
resque-bus-0.6.0	spec/adapter/support.rb
resque-bus-0.5.12	spec/adapter/support.rb
resque-bus-0.5.11	spec/adapter/support.rb
resque-bus-0.5.10	spec/adapter/support.rb
resque-bus-0.5.9	spec/adapter/support.rb
resque-bus-0.5.8	spec/adapter/support.rb
resque-bus-0.5.7	spec/adapter/support.rb