module Rack::App::Worker::Environment

Constants

DEFAULT_HEARTBEAT_INTERVAL
DEFAULT_MAX_CONSUMER_NUMBER
DEFAULT_MESSAGE_COUNT_LIMIT
DEFAULT_QOS
DEFAULT_WORKER_CLUSTER
DEFAULT_WORKER_NAMESPACE

Public Instance Methods

heartbeat_interval() click to toggle source
# File lib/rack/app/worker/environment.rb, line 24
def heartbeat_interval
  (ENV['WORKER_HEARTBEAT_INTERVAL'] || DEFAULT_HEARTBEAT_INTERVAL).to_i
end
log_level() click to toggle source
# File lib/rack/app/worker/environment.rb, line 36
def log_level
  case ENV['WORKER_LOG_LEVEL'].to_s.upcase

    when 'DEBUG', '0'
      0

    when 'INFO', '1'
      1

    when 'WARN', '2'
      2

    when 'ERROR', '3'
      3

    when 'FATAL', '4'
      4

    when 'UNKNOWN', '5'
      5

    else
      3

  end
end
max_consumer_number() click to toggle source
# File lib/rack/app/worker/environment.rb, line 32
def max_consumer_number
  (ENV['WORKER_MAX_CONSUMER_NUMBER'] || DEFAULT_MAX_CONSUMER_NUMBER).to_i
end
message_count_limit() click to toggle source
# File lib/rack/app/worker/environment.rb, line 28
def message_count_limit
  (ENV['WORKER_MESSAGE_COUNT_LIMIT'] || DEFAULT_MESSAGE_COUNT_LIMIT).to_i
end
namespace() click to toggle source
# File lib/rack/app/worker/environment.rb, line 20
def namespace
  (ENV['WORKER_NAMESPACE'] || DEFAULT_WORKER_NAMESPACE).to_s
end
queue_qos() click to toggle source
# File lib/rack/app/worker/environment.rb, line 16
def queue_qos
  (ENV['WORKER_QOS'] || DEFAULT_QOS).to_i
end
stderr() click to toggle source
# File lib/rack/app/worker/environment.rb, line 67
def stderr
  (ENV['WORKER_STDERR'] || $stderr).to_s
end
stdout() click to toggle source
# File lib/rack/app/worker/environment.rb, line 63
def stdout
  (ENV['WORKER_STDOUT'] || $stdout).to_s
end
worker_cluster() click to toggle source
# File lib/rack/app/worker/environment.rb, line 12
def worker_cluster
  (ENV['WORKER_CLUSTER'] || DEFAULT_WORKER_CLUSTER).to_s
end