module Kyu::Worker::ClassMethods

Public Instance Methods

error_callback( error_callback ) click to toggle source
# File lib/kyu/worker.rb, line 33
def error_callback( error_callback )
  @error_callback = error_callback
end
logger( logger ) click to toggle source
# File lib/kyu/worker.rb, line 29
def logger( logger )
  @logger = logger
end
max_retries( max_retries ) click to toggle source
# File lib/kyu/worker.rb, line 21
def max_retries( max_retries )
  @max_retries = max_retries
end
queue_options( queue_options ) click to toggle source
# File lib/kyu/worker.rb, line 37
def queue_options( queue_options )
  @queue_options = queue_options
end
start( queue_name ) click to toggle source
# File lib/kyu/worker.rb, line 10
def start( queue_name )
  options = {}
  options.merge!( max_retries: @max_retries ) unless @max_retries.nil?
  options.merge!( threadpool_size: @threadpool_size ) unless @threadpool_size.nil?
  options.merge!( logger: @logger ) unless @logger.nil?
  options.merge!( error_callback: @error_callback ) unless @error_callback.nil?
  options.merge!( queue_options: @queue_options ) unless @queue_options.nil?

  Manager.new( self, queue_name, options ).start
end
threadpool_size( threadpool_size ) click to toggle source
# File lib/kyu/worker.rb, line 25
def threadpool_size( threadpool_size )
  @threadpool_size = threadpool_size
end