Module: Qs::Daemon::ClassMethods

Defined in:

lib/qs/daemon.rb

Instance Method Summary

• #configuration ⇒ Object
• #error(&block) ⇒ Object
• #init(&block) ⇒ Object
• #logger(*args) ⇒ Object
• #max_workers(*args) ⇒ Object
• #min_workers(*args) ⇒ Object
• #name(*args) ⇒ Object
• #on_worker_shutdown(&block) ⇒ Object
• #on_worker_sleep(&block) ⇒ Object
• #on_worker_start(&block) ⇒ Object
• #on_worker_wakeup(&block) ⇒ Object
• #pid_file(*args) ⇒ Object
• #queue(queue) ⇒ Object
• #shutdown_timeout(*args) ⇒ Object
• #verbose_logging(*args) ⇒ Object
• #workers(*args) ⇒ Object

Instance Method Details

#configuration ⇒ Object

# File 'lib/qs/daemon.rb', line 237

def configuration
  @configuration ||= Configuration.new
end

#error(&block) ⇒ Object

# File 'lib/qs/daemon.rb', line 294

def error(&block)
  self.configuration.error_procs << block
end

#init(&block) ⇒ Object

# File 'lib/qs/daemon.rb', line 290

def init(&block)
  self.configuration.init_procs << block
end

#logger(*args) ⇒ Object

# File 'lib/qs/daemon.rb', line 282

def logger(*args)
  self.configuration.logger(*args)
end

#max_workers(*args) ⇒ Object

# File 'lib/qs/daemon.rb', line 253

def max_workers(*args)
  self.configuration.max_workers(*args)
end

#min_workers(*args) ⇒ Object

# File 'lib/qs/daemon.rb', line 249

def min_workers(*args)
  self.configuration.min_workers(*args)
end

#name(*args) ⇒ Object

# File 'lib/qs/daemon.rb', line 241

def name(*args)
  self.configuration.name(*args)
end

#on_worker_shutdown(&block) ⇒ Object

# File 'lib/qs/daemon.rb', line 266

def on_worker_shutdown(&block)
  self.configuration.worker_shutdown_procs << block
end

#on_worker_sleep(&block) ⇒ Object

# File 'lib/qs/daemon.rb', line 270

def on_worker_sleep(&block)
  self.configuration.worker_sleep_procs << block
end

#on_worker_start(&block) ⇒ Object

# File 'lib/qs/daemon.rb', line 262

def on_worker_start(&block)
  self.configuration.worker_start_procs << block
end

#on_worker_wakeup(&block) ⇒ Object

# File 'lib/qs/daemon.rb', line 274

def on_worker_wakeup(&block)
  self.configuration.worker_wakeup_procs << block
end

#pid_file(*args) ⇒ Object

# File 'lib/qs/daemon.rb', line 245

def pid_file(*args)
  self.configuration.pid_file(*args)
end

#queue(queue) ⇒ Object

# File 'lib/qs/daemon.rb', line 298

def queue(queue)
  self.configuration.queues << queue
end

#shutdown_timeout(*args) ⇒ Object

# File 'lib/qs/daemon.rb', line 286

def shutdown_timeout(*args)
  self.configuration.shutdown_timeout(*args)
end

#verbose_logging(*args) ⇒ Object

# File 'lib/qs/daemon.rb', line 278

def verbose_logging(*args)
  self.configuration.verbose_logging(*args)
end

#workers(*args) ⇒ Object

# File 'lib/qs/daemon.rb', line 257

def workers(*args)
  self.min_workers(*args)
  self.max_workers(*args)
end