Contents

class LowPriorityWorker
  include Shoryuken::Worker

  shoryuken_options queue: 'low_priority', delete: true, batch: true

  def perform(sqs_msgs, bodies)
    bodies.each_with_index do |body, index|
      puts "LowPriorityWorker (#{index}): '#{body}'"
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
shoryuken-0.0.3	examples/low_priority_worker.rb