Contents

module Refinery #:nodoc:
  # A queue provider for beanstalk
  class BeanstalkQueueProvider
    include Refinery::Loggable
    
    attr_reader :queues
    
    # Initialize the queue provider
    def initialize(hosts=nil)
      @hosts = hosts
      @queues = {}
    end
    # Get the named queue
    def queue(name)
      queues[name] ||= Refinery::BeanstalkQueue.new(name, @hosts)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
refinery-0.12.2	lib/refinery/beanstalk_queue_provider.rb
refinery-0.12.1	lib/refinery/beanstalk_queue_provider.rb
refinery-0.12.0	lib/refinery/beanstalk_queue_provider.rb
refinery-0.11.0	lib/refinery/beanstalk_queue_provider.rb