Class: QueueClassicMatchers::TestWorker
- Inherits:
-
QC::Worker
- Object
- QC::Worker
- QueueClassicMatchers::TestWorker
- Defined in:
- lib/queue_classic_matchers/test_worker.rb
Instance Method Summary collapse
- #handle_failure(job, e) ⇒ Object
-
#initialize(options) ⇒ TestWorker
constructor
A new instance of TestWorker.
- #klasses ⇒ Object
- #process(queue, job) ⇒ Object
Constructor Details
#initialize(options) ⇒ TestWorker
Returns a new instance of TestWorker.
3 4 5 6 |
# File 'lib/queue_classic_matchers/test_worker.rb', line 3 def initialize() @klasses = .delete(:klasses) super() end |
Instance Method Details
#handle_failure(job, e) ⇒ Object
8 9 10 |
# File 'lib/queue_classic_matchers/test_worker.rb', line 8 def handle_failure(job, e) raise e end |
#klasses ⇒ Object
24 25 26 |
# File 'lib/queue_classic_matchers/test_worker.rb', line 24 def klasses @klasses.map(&:to_s) end |
#process(queue, job) ⇒ Object
12 13 14 15 16 17 18 19 20 21 22 |
# 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 |