Contents

# > bundle exec ruby examples/demo_oneoff.rb
$: << File.expand_path('../examples', File.dirname(__FILE__))
require 'pika_que'

require 'dev_worker'

PikaQue.logger.level = ::Logger::DEBUG

begin
  pro = DevWorker.new(concurrency: 2)
  pro.start
rescue => e
  puts e
  puts e.backtrace.join("\n")
end

sleep 3

300.times do |i|
  DevWorker.enqueue({ msg: "hello world #{i}" })
end

sleep 3

pro.stop

puts "bye"

exit 1

Version data entries

9 entries across 9 versions & 1 rubygems

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