Skip to content

Instantly share code, notes, and snippets.

@drsnyder
Created May 15, 2013 00:08
Show Gist options
  • Save drsnyder/5580735 to your computer and use it in GitHub Desktop.
Save drsnyder/5580735 to your computer and use it in GitHub Desktop.
peek and delete jobs
require 'rubygems'
require 'beaneater'
require 'json'
require 'pp'
beanstalk = Beaneater::Pool.new(['localhost:11300'])
tube = beanstalk.tubes["huddlerXheadfi.BasicObject"]
(0..1000).each do |i|
break if not tube.peek(:ready)
job = tube.reserve
data = JSON.parse(job.body)
if data['payload']['params'].has_key?('findAdditionalExternalListings')
puts "Deleting"
job.delete
else
puts "Skipping"
#job.release
end
end
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment