queue_daemon

#!/usr/bin/env ruby

require 'bundler/setup'
require 'dante'
require 'beaneater'

Dante.run('mailer') do |opts|
  # Connect to beanstalkd on default ports
  beanstalk = Beaneater::Pool.new ['localhost:11300']

  beanstalk.jobs.register(options.queue) do |job|
    # This is useful for integration testing or if you wish to gracefully stop processing before killing the daemon
    raise Beaneater::AbortProcessingError if job.body == "no_more_beans"
    # process the job for example
    ExampleMailer.send_test(job).deliver
  end
    
  beanstalk.jobs.process!
end