Why Gemfury? Push, build, and install  RubyGems npm packages Python packages Maven artifacts PHP packages Go Modules Debian packages RPM packages NuGet packages

Repository URL to install this package:

Details    
frenzy_bunnies / examples / feed_worker.rb
Size: Mime:
$:<< File.expand_path('../lib', File.dirname(__FILE__))

require 'rubygems'
require 'frenzy_bunnies'

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

f = FrenzyBunnies::Context.new

f.run FeedWorker,FeedDownloader


trap "INT" do
  f.stop
  exit!
end