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