Class: BatchProcessor::Processors::Parallel

Inherits:

BatchProcessor::ProcessorBase

• Object
• Spicerack::InputObject
• BatchProcessor::ProcessorBase
• BatchProcessor::Processors::Parallel

Defined in:

lib/batch_processor/processors/parallel.rb

Instance Method Summary

• #process_collection_item(item) ⇒ Object

Methods inherited from BatchProcessor::ProcessorBase

disable_retries?

Methods included from BatchProcessor::Processor::Execute

#execute

Methods included from BatchProcessor::Processor::Process

#process

Instance Method Details

#process_collection_item(item) ⇒ Object

# File 'lib/batch_processor/processors/parallel.rb', line 9

def process_collection_item(item)
  job = batch.job_class.new(item)
  job.batch_id = batch.batch_id
  job.enqueue
end