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