daemon.rb

DaemonKit::AMQP.run do
  amq = ::MQ.new
  amq.prefetch(20)
  amq.queue('jobs').subscribe( :ack => true ) do |info, msg|
    job = Marshal.load(msg)
    actual_job = job[:type].constantize.send(:new, job[:id])
    safely do
      EM.defer(proc { actual_job.run }, proc { info.ack })
    end
  end
end

gistfile1.rb

[DEBUG] tweetbots-daemon.rb:9: [#<Thread:0x8fc98bc dead>, #<Thread:0x8fc9858 dead>, #<Thread:0x8fc97f4 dead>, #<Thread:0x8fc9790 dead>, #<Thread:0x8fc972c dead>, #<Thread:0x8fc96c8 dead>, #<Thread:0x8fc9664 dead>, #<Thread:0x8fc9600 dead>, #<Thread:0x8fc959c dead>, #<Thread:0x8fc9538 dead>, #<Thread:0x8fc94d4 dead>, #<Thread:0x8fc9470 dead>, #<Thread:0x8fc940c dead>, #<Thread:0x8fc93a8 dead>, #<Thread:0x8fc9344 dead>, #<Thread:0x8fc92e0 dead>, #<Thread:0x8fc927c dead>, #<Thread:0x8fc9218 dead>, #<Thread:0x8fc91b4 dead>, #<Thread:0x8fc9150 dead>]