Contents

require_relative '../lib/upperkut/worker'
require_relative '../lib/upperkut/strategies/scheduled_queue'

class ScheduledWorker
  include Upperkut::Worker

  setup_upperkut do |config|
    config.strategy = Upperkut::Strategies::ScheduledQueue.new(
      self,
      batch_size: 200
    )
  end

  def perform(items)
    items.each do |item|
      puts "event dispatched: #{item.inspect}"
    end
  end
end

Version data entries

8 entries across 8 versions & 1 rubygems

Version	Path
upperkut-1.0.4	examples/scheduled_worker.rb
upperkut-1.0.2	examples/scheduled_worker.rb
upperkut-1.0.0.rc	examples/scheduled_worker.rb
upperkut-0.8.1	examples/scheduled_worker.rb
upperkut-0.8.0	examples/scheduled_worker.rb
upperkut-0.7.5	examples/scheduled_worker.rb
upperkut-0.7.4	examples/scheduled_worker.rb
upperkut-0.7.2	examples/scheduled_worker.rb