module ActiveBeaneater

Constants

VERSION

Public Class Methods

configure() { |config| ... } click to toggle source

# File lib/active_beaneater.rb, line 17
def self.configure

  url = ENV['BEANSTALK_URL']
  url ||=  ['beanstalk://localhost']
  uri = URI(url)


  config = {
    client: Beaneater.new("#{uri.host}:#{uri.port}"),
    prefix: 'active-beaneater'
  }

  config = OpenStruct.new(config)
  yield(config) if block_given?


  Rails.application.config.beaneater = config.freeze
end

resolve_queue_name(queue) click to toggle source

# File lib/active_beaneater.rb, line 36
def self.resolve_queue_name(queue)
  prefix = Rails.application.config.beaneater.prefix
  prefix = [prefix] if !prefix.respond_to?(:to_ary)
  (prefix + [queue]).join('.')
end