Create a gist now

Instantly share code, notes, and snippets.

Example dante daemon with beanstalkd
#!/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
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment