class Leveret::Configuration
Contains everything needed to configure leveret for work. Sensible defaults are included and will be initialized with the class.
@!attribute amqp
@return [String] Location of your RabbitMQ server. Default: +"amqp://guest:guest@localhost:5672/"+
@!attribute exchange_name
@return [String] Name of the exchange for Leveret to publish messages to. Default: +"leveret_exch"+
@!attribute queue_name_prefix
@return [String] This value will be prefixed to all queues created on your RabbitMQ instance. Default: +"leveret_queue"+
@!attribute delay_exchange_name
@return [String] Name of the exchange for Leveret to publish to that should be processed later. Default: +"leveret_delay_exch"+
@!attribute delay_queue_name
@return [String] Name of the queue for Leveret to use to store messages that should be processed later. Default: +"leveret_delay_queue"+
@!attribute delay_time
@return [Integer] Amount of time a delayed message should say on the delay queue in milliseconds Default: +10000+
@!attribute delay_exchange_name
@return [String] Name of the exchange for Leveret to publish messages to. Default: +"leveret_exch"+
@!attribute log_file
@return [String] The path where logfiles should be written to. Default: +STDOUT+
@!attribute log_level
@return [Integer] The log severity which should be output to the log. Default: +Logger::DEBUG+
@!attribute default_queue_name
@return [String] The name of the queue that will be use unless explicitly specified in a job. Default: +"standard"+
@!attribute after_fork
@return [Proc] A proc which will be executed in a child after forking to process a message. Default: +proc {}+
@!attribute error_handler
@return [Proc] A proc which will be called if a job raises an exception. Default: +proc {|ex| ex }+
@!attribute concurrent_fork_count
@return [Integer] The number of jobs that can be processes simultanously. Default: +1+
Attributes
after_fork[RW]
amqp[RW]
concurrent_fork_count[RW]
default_queue_name[RW]
delay_exchange_name[RW]
delay_queue_name[RW]
delay_time[RW]
error_handler[RW]
exchange_name[RW]
log_file[RW]
log_level[RW]
queue_name_prefix[RW]
Public Class Methods
new()
click to toggle source
Create a new instance of Configuration
with a set of sane defaults.
# File lib/leveret/configuration.rb, line 40 def initialize assign_defaults end
Private Instance Methods
assign_defaults()
click to toggle source
# File lib/leveret/configuration.rb, line 46 def assign_defaults self.amqp = "amqp://guest:guest@localhost:5672" self.exchange_name = 'leveret_exch' self.log_file = STDOUT self.log_level = Logger::DEBUG self.queue_name_prefix = 'leveret_queue' self.default_queue_name = 'standard' self.delay_exchange_name = 'leveret_delay_exch' self.delay_queue_name = 'leveret_delay_queue' self.delay_time = 10_000 self.after_fork = proc {} self.error_handler = proc { |ex| ex } self.concurrent_fork_count = 1 end