Contents

class QueueLoop < Loops::Queue
  def process_message(message)
    debug "Received a message: #{message.body}"
    debug "sleeping..."
    sleep(0.5 + rand(10) / 10.0)
    debug "done..."
  end
end

Version data entries

13 entries across 13 versions & 2 rubygems

Version	Path
loops-2.0.9	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.8	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.7	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.6	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.5	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.4	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.3	generators/loops/templates/app/loops/queue_loop.rb
qik-loops-2.1.4	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.2	generators/loops/templates/app/loops/queue_loop.rb
qik-loops-2.1.3	generators/loops/templates/app/loops/queue_loop.rb
qik-loops-2.1.0	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.1	generators/loops/templates/app/loops/queue_loop.rb
loops-2.0.0	generators/loops/templates/app/loops/queue_loop.rb