Last active

Embed URL

HTTPS clone URL

SSH clone URL

You can clone with HTTPS or SSH.

Download Gist

Example dante daemon with beanstalkd

View queue_daemon
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19
#!/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
Something went wrong with that request. Please try again.