Contents

class DefaultWorker
  include Shoryuken::Worker

  shoryuken_options queue: 'default', delete: true, body_parser: ->(sqs_msg){ "new body: #{sqs_msg.body}" }

  def perform(sqs_msg, body)
    puts "DefaultWorker: '#{body}'"
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
shoryuken-0.0.3	examples/default_worker.rb