Contents

class FeedWorker
  include FrenzyBunnies::Worker
  from_queue 'new.feeds', :prefetch => 20, :threads => 13, :durable => true

  def work(msg)
    puts msg
    ack!
  end
end

class FeedDownloader
  include FrenzyBunnies::Worker
  from_queue 'new.downloads', :durable => true
  def work(msg)
    puts msg
    ack!
  end
end

Version data entries

16 entries across 16 versions & 2 rubygems

Version	Path
boardintel_frenzy_bunnies-0.0.17-java	examples/feed_workers_bin.rb
boardintel_frenzy_bunnies-0.0.16	examples/feed_workers_bin.rb
boardintel_frenzy_bunnies-0.0.15	examples/feed_workers_bin.rb
boardintel_frenzy_bunnies-0.0.14	examples/feed_workers_bin.rb
boardintel_frenzy_bunnies-0.0.13	examples/feed_workers_bin.rb
boardintel_frenzy_bunnies-0.0.12	examples/feed_workers_bin.rb
boardintel_frenzy_bunnies-0.0.11	examples/feed_workers_bin.rb
boardintel_frenzy_bunnies-0.0.9	examples/feed_workers_bin.rb
frenzy_bunnies-0.0.8	examples/feed_workers_bin.rb
frenzy_bunnies-0.0.7	examples/feed_workers_bin.rb
frenzy_bunnies-0.0.6	examples/feed_workers_bin.rb
frenzy_bunnies-0.0.5	examples/feed_workers_bin.rb
frenzy_bunnies-0.0.4	examples/feed_workers_bin.rb
frenzy_bunnies-0.0.3	examples/feed_workers_bin.rb
frenzy_bunnies-0.0.2	examples/feed_workers_bin.rb
frenzy_bunnies-0.0.1	examples/feed_workers_bin.rb