Module: DisqueJockey

Defined in:
lib/disque_jockey/worker_group.rb,
lib/disque_jockey.rb,
lib/disque_jockey/cli.rb,
lib/disque_jockey/broker.rb,
lib/disque_jockey/logger.rb,
lib/disque_jockey/worker.rb,
lib/disque_jockey/version.rb,
lib/disque_jockey/cli/help.rb,
lib/disque_jockey/supervisor.rb,
lib/disque_jockey/worker_pool.rb,
lib/disque_jockey/configuration.rb

Overview

A WorkerGroup lives in its own process and runs workers of each worker class. It is effectively a self-contained unit of workers that fetch jobs and work.

Defined Under Namespace

Classes: Broker, CLI, Configuration, Logger, Supervisor, Worker, WorkerGroup, WorkerPool

Constant Summary collapse

VERSION =
'0.0.3'

Class Method Summary collapse

Class Method Details

.configurationObject



18
19
20
# File 'lib/disque_jockey.rb', line 18

def self.configuration
  @configuration ||= DisqueJockey::Configuration.new
end

.configure {|configuration| ... } ⇒ Object

Yields:



22
23
24
# File 'lib/disque_jockey.rb', line 22

def self.configure
  yield(configuration)
end

.run!(options = {}) ⇒ Object



26
27
28
29
30
# File 'lib/disque_jockey.rb', line 26

def self.run!(options={})
  @configuration = DisqueJockey::Configuration.new(options)

  DisqueJockey::Supervisor.work!
end