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