Class: Rosette::Queuing::Worker

Inherits:

Object

• Object
• Rosette::Queuing::Worker

Defined in:

lib/rosette/queuing/worker.rb

Overview

Base class for Rosette queue worker implementations. Really just an interface.

Instance Method Summary

• #initialize(rosette_config, logger, options = {}) ⇒ Worker constructor

  Creates a new worker instance.

• #start ⇒ void

  Tells this worker to start processing jobs.

Constructor Details

#initialize(rosette_config, logger, options = {}) ⇒ Worker

Creates a new worker instance. Options vary per implementation.

Parameters:

• rosette_config (Configurator) —

  The Rosette config to use.

• logger (Logger) —

  The logger to print messages with.

• options (Hash) (defaults to: {}) —

  A hash of options used by the underlying queue implementation.

# File 'lib/rosette/queuing/worker.rb', line 16

def initialize(rosette_config, logger, options = {})
end

Instance Method Details

#start ⇒ void

This method returns an undefined value.

Tells this worker to start processing jobs. Should block. If not implemented by the derived class, raises NotImplementedError.

Raises:

• (NotImplementedError)

# File 'lib/rosette/queuing/worker.rb', line 23

def start
  raise NotImplementedError,
    'expected to be implemented in derived classes'
end