Method: FluQ::Worker#initialize

Defined in:
lib/fluq/worker.rb

#initialize(prefix, handlers = []) ⇒ Worker

Returns a new instance of Worker.

Parameters:

  • handlers (Array<Class,Array>) (defaults to: []) —

    handler builders



9
10
11
12
13
14
15
16
17
 
# File 'lib/fluq/worker.rb', line 9

def initialize(prefix, handlers = [])
  @prefix   = prefix
  @handlers = []
  @observer = observe

  handlers.each do |klass, *args|
    add klass, *args
  end
end