class Jobster::Config
Attributes
bunny[W]
delay_exchange_name[W]
delay_queue_name[W]
exchange_name[W]
logger[W]
queue_name_prefix[W]
worker_threads[W]
Public Instance Methods
bunny()
click to toggle source
# File lib/jobster/config.rb, line 4 def bunny @bunny ||= begin connection = Bunny.new connection.start connection end end
delay_exchange_name()
click to toggle source
# File lib/jobster/config.rb, line 23 def delay_exchange_name @delay_exchange_name || "#{self.exchange_name}-delay-exch" end
delay_queue_name()
click to toggle source
# File lib/jobster/config.rb, line 28 def delay_queue_name @delay_queue_name || "#{self.exchange_name}-delay-queue" end
exchange_name()
click to toggle source
# File lib/jobster/config.rb, line 18 def exchange_name @exchange_name || "jobster" end
logger()
click to toggle source
# File lib/jobster/config.rb, line 13 def logger @logger ||= Logger.new(STDOUT) end
queue_name_prefix()
click to toggle source
# File lib/jobster/config.rb, line 33 def queue_name_prefix @queue_name_prefix || "#{self.exchange_name}-queue" end
worker_callback(name, &block)
click to toggle source
# File lib/jobster/config.rb, line 47 def worker_callback(name, &block) worker_callbacks[name.to_sym] ||= [] worker_callbacks[name.to_sym] << block end
worker_callbacks()
click to toggle source
# File lib/jobster/config.rb, line 43 def worker_callbacks @worker_callbacks ||= {} end
worker_error_handler(&block)
click to toggle source
# File lib/jobster/config.rb, line 56 def worker_error_handler(&block) worker_error_handlers << block end
worker_error_handlers()
click to toggle source
# File lib/jobster/config.rb, line 52 def worker_error_handlers @worker_error_handlers ||= [] end
worker_threads()
click to toggle source
# File lib/jobster/config.rb, line 38 def worker_threads @worker_threads || 1 end