Contents

require 'pika_que/worker'
require 'pika_que/handlers/error_handler'

class DemoWorker
  include PikaQue::Worker
  from_queue "pika-que-demo"
  handle_with PikaQue::Handlers::ErrorHandler

  def perform(msg)
    logger.info msg["msg"]
    if rand(2) == 1
      raise "BOOM!"
    end
    ack!
  end

end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
pika_que-0.3.0	examples/demo_worker.rb
pika_que-0.2.0	examples/demo_worker.rb
pika_que-0.1.6	examples/demo_worker.rb
pika_que-0.1.5	examples/demo_worker.rb
pika_que-0.1.4	examples/demo_worker.rb
pika_que-0.1.3	examples/demo_worker.rb
pika_que-0.1.2	examples/demo_worker.rb
pika_que-0.1.1	examples/demo_worker.rb
pika_que-0.1.0	examples/demo_worker.rb