Class: Refinery::BeanstalkQueueProvider

Inherits:

Object

• Object
• Refinery::BeanstalkQueueProvider

Includes:

Loggable

Defined in:

lib/refinery/beanstalk_queue_provider.rb

Overview

A queue provider for beanstalk

Instance Attribute Summary

• #queues ⇒ Object readonly

  Returns the value of attribute queues.

Instance Method Summary

• #initialize(hosts = nil) ⇒ BeanstalkQueueProvider constructor

  Initialize the queue provider.

• #queue(name) ⇒ Object

  Get the named queue.

Methods included from Loggable

#logger

Constructor Details

#initialize(hosts = nil) ⇒ BeanstalkQueueProvider

Initialize the queue provider

# File 'lib/refinery/beanstalk_queue_provider.rb', line 9

def initialize(hosts=nil)
  @hosts = hosts
  @queues = {}
end

Instance Attribute Details

#queues ⇒ Object (readonly)

Returns the value of attribute queues.

# File 'lib/refinery/beanstalk_queue_provider.rb', line 6

def queues
  @queues
end

Instance Method Details

#queue(name) ⇒ Object

Get the named queue

# File 'lib/refinery/beanstalk_queue_provider.rb', line 14

def queue(name)
  queues[name] ||= Refinery::BeanstalkQueue.new(name, @hosts)
end