class QueueClassicMatchers::TestWorker

Public Class Methods

new(options) click to toggle source
Calls superclass method
# File lib/queue_classic_matchers/test_worker.rb, line 3
def initialize(options)
  @klasses = options.delete(:klasses)
  super(options)
end

Public Instance Methods

handle_failure(job, e) click to toggle source
# File lib/queue_classic_matchers/test_worker.rb, line 8
def handle_failure(job, e)
  raise e
end
klasses() click to toggle source
# File lib/queue_classic_matchers/test_worker.rb, line 24
def klasses
  @klasses.map(&:to_s)
end
process(queue, job) click to toggle source
Calls superclass method
# File lib/queue_classic_matchers/test_worker.rb, line 12
def process(queue, job)
  # Skip over task not matching klasses
  k = job[:method].split('.').first
  if @klasses.nil? || klasses.include?(k)
    super
  else
    # Uncomment for debugging
    # puts "Skipping #{job[:method]}. Klassed: #{klasses.inspect}"
    queue.delete(job[:id])
  end
end