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