class Fluere::Worker::Base

Public Instance Methods

aws_flow_worker() click to toggle source
# File lib/fluere/worker.rb, line 16
def aws_flow_worker
  @aws_flow_worker ||= worker_class.new(
    Fluere.swf.client,
    Fluere.domain,
    task_list,
    *task_implementations
  ) {{
    logger:      Fluere::Config.logger,
    use_forking: Fluere::Config.use_forking
  }}
end
register() click to toggle source
# File lib/fluere/worker.rb, line 36
def register
  aws_flow_worker.register
end
run_once() click to toggle source
# File lib/fluere/worker.rb, line 32
def run_once
  aws_flow_worker.run_once
end
start() click to toggle source
# File lib/fluere/worker.rb, line 28
def start
  aws_flow_worker.start
end
task_implementations() click to toggle source
# File lib/fluere/worker.rb, line 12
def task_implementations
  raise("abstract")
end
task_list() click to toggle source
# File lib/fluere/worker.rb, line 4
def task_list
  raise("abstract")
end
worker_class() click to toggle source
# File lib/fluere/worker.rb, line 8
def worker_class
  raise("abstract")
end