class SidekiqStrategies::BeanstalkdHandler

Constants

TIME_TO_RUN

Attributes

connection[RW]

Public Class Methods

new(connection=nil) click to toggle source
# File lib/sidekiq_strategies/beanstalkd_handler.rb, line 8
def initialize(connection=nil)
  @connection = connection
end

Public Instance Methods

find_job(id) click to toggle source
# File lib/sidekiq_strategies/beanstalkd_handler.rb, line 16
def find_job(id)
  conn.jobs.find_all(id).shift
end
obtain_tube(name) click to toggle source
# File lib/sidekiq_strategies/beanstalkd_handler.rb, line 12
def obtain_tube(name)
  conn.tubes[name]
end

Private Instance Methods

conn() click to toggle source
# File lib/sidekiq_strategies/beanstalkd_handler.rb, line 22
def conn
  @connection ||= Beaneater::Pool.new(host)
end
host() click to toggle source
# File lib/sidekiq_strategies/beanstalkd_handler.rb, line 26
def host
  @host ||= 'localhost:11300'
end