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