Contents

require 'beanstalk-client'

module Quebert
  module Backend
    
    # Manage jobs on a Beanstalk queue out of process
    class Beanstalk < Beanstalk::Pool
      def put(job, *args)
        super job.to_json, *args
      end
      
      def reserve_with_controller
        Controller::Beanstalk.new(reserve_without_controller, self)
      end
      alias :reserve_without_controller :reserve
      alias :reserve :reserve_with_controller
      
      # For testing purposes... I think there's a better way to do this though.
      def drain!
        while peek_ready do
          reserve_without_controller.delete
        end
        while peek_delayed do
          reserve_without_controller.delete
        end
        while job = peek_buried do
          last_conn.kick 1 # what? Why the 1? it kicks them all?
          reserve_without_controller.delete
        end
      end
      
      def initialize(host, *args)
        super Array(host), *args
      end
      def self.configure(opts={})
        opts[:host] ||= ['127.0.0.1:11300']
        new(opts[:host], opts[:tube])
      end
    end
  end
end

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
quebert-1.0.9	lib/quebert/backend/beanstalk.rb
quebert-1.0.8	lib/quebert/backend/beanstalk.rb
quebert-1.0.7	lib/quebert/backend/beanstalk.rb
quebert-1.0.6	lib/quebert/backend/beanstalk.rb
quebert-1.0.5	lib/quebert/backend/beanstalk.rb
quebert-1.0.4	lib/quebert/backend/beanstalk.rb
quebert-1.0.2	lib/quebert/backend/beanstalk.rb